jira  

Messages by Thread

• [jira] [Assigned] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings Muralidhar Basani (Jira)
• [PR] KAFKA-20245: DLQ records exceeding max delivery count. [kafka] via GitHub
• [PR] KAFKA-9914: Fix replication cycle detection [kafka] via GitHub
• Re: [PR] Kafka changes [kafka] via GitHub
• Re: [PR] KAFKA-19106 : Improve SourceTask commit() hook [kafka] via GitHub
• Re: [PR] MINOR: Remove the flaky streams admin api test - describe streams group with short timeout [kafka] via GitHub
  • Re: [PR] MINOR: Remove the flaky streams admin api test - describe streams group with short timeout [kafka] via GitHub
• Re: [PR] [WIP]KAFKA-19000 Flaky test report should use absolute time for links [kafka] via GitHub
• [PR] KAFKA-16263: Add listeners and callbacks section to Streams developer guide [kafka] via GitHub
• [jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback minjcho (Jira)
• [jira] [Assigned] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback minjcho (Jira)
• [jira] [Updated] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench Lianet Magrans (Jira)
• [PR] KAFKA-20384: Add a unit test for reproducing per-record context [kafka] via GitHub
• [PR] KAFKA-20461: Support -1 (infinite retention) for offsets.retention.minutes [kafka] via GitHub
  • Re: [PR] KAFKA-20461: Support -1 (infinite retention) for offsets.retention.minutes [kafka] via GitHub
• [jira] [Updated] (KAFKA-20461) Support -1 (infinite retention) for offsets.retention.minutes Edward (Jira)
• [jira] [Created] (KAFKA-20461) Support -1 (infinite retention) for offsets.retention.minutes Edward (Jira)
• [jira] [Commented] (KAFKA-20453) Metrics of group "kafka.network.SocketServer" should have tags unique to each SocketServer Edoardo Comar (Jira)
• [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka] via GitHub
• [jira] [Assigned] (KAFKA-9368) Preserve stream-time across rebalances/restarts Alieh Saeedi (Jira)
• [jira] [Comment Edited] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
• [jira] [Commented] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
  • [jira] [Commented] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
• [jira] [Updated] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
  • [jira] [Updated] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
  • [jira] [Updated] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
• [jira] [Created] (KAFKA-20460) Potential delivery slow-down for record-limit share consumers when draining record backlog Andrew Schofield (Jira)
• [PR] KAFKA-20453: Add nodeId and listenerType tags to SocketServer metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20453: Add nodeId and listenerType tags to SocketServer metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20453: Add nodeId and listenerType tags to SocketServer metrics [kafka] via GitHub
• [jira] [Created] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported Hareesh Billa (Jira)
• [jira] [Assigned] (KAFKA-20458) AcknowledgeType.RENEW re-delivers records to application via poll() in explicit acknowledgement mode, undocumented and inconsistent with broker-side contract Shekhar Prasad Rajak (Jira)
• [jira] [Created] (KAFKA-20458) AcknowledgeType.RENEW re-delivers records to application via poll() in explicit acknowledgement mode, undocumented and inconsistent with broker-side contract Shekhar Prasad Rajak (Jira)
• [jira] [Comment Edited] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition chomingi (Jira)
• [jira] [Commented] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition chomingi (Jira)
• [jira] [Commented] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset Daeho Kwon (Jira)
• Re: [PR] MINOR: Optimize ClientQuotasImage lookup (KAFKA-13022) [kafka] via GitHub
• Re: [PR] KAFKA-19971: Fix IllegalStateException from using entries after cache eviction [kafka] via GitHub
  • Re: [PR] KAFKA-19971: Fix IllegalStateException from using entries after cache eviction [kafka] via GitHub
• Re: [PR] KAFKA-19967: Reduce GC pressure in tiered storage read path using direct memory buffers [kafka] via GitHub
  • Re: [PR] KAFKA-19967: Reduce GC pressure in tiered storage read path using direct memory buffers [kafka] via GitHub
• Re: [PR] KAFKA-19969: Add Per-Topic Observability Metrics for Remote Fetch Quota Enforcement [kafka] via GitHub
  • Re: [PR] KAFKA-19969: Add Per-Topic Observability Metrics for Remote Fetch Quota Enforcement [kafka] via GitHub
• Re: [PR] (WIP) KAFKA-19261 Move ConnectionQuotas to server module [kafka] via GitHub
• [jira] [Created] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-20253) High CPU loop on consumer after failed re-authentication chomingi (Jira)
  • [jira] [Assigned] (KAFKA-20253) High CPU loop on consumer after failed re-authentication chomingi (Jira)
• [PR] KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException [kafka] via GitHub
• [PR] MINOR: KAFKA-20297: move Crc32C Checksums and Sanitizer from utils to utils.internals [kafka] via GitHub
  • Re: [PR] KAFKA-20297 move Crc32C Checksums and Sanitizer from utils to utils.internals [kafka] via GitHub
• [jira] [Created] (KAFKA-20456) Task not found in StateUpdater throwing an exception and causing unnecessary retoration Bill Bejeck (Jira)
• [PR] KAFKA-20455: Wait for all producers to send startup_complete before executing system test [kafka] via GitHub
• [jira] [Updated] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test Kirk True (Jira)
• [jira] [Created] (KAFKA-20455) Add timeout to verifiable_producer Kirk True (Jira)
• [jira] [Commented] (KAFKA-20454) Verify that `bin/kafka-consumer-groups.sh --reset-offsets` fails for "streams" group Szabolcs Stremler (Jira)
• [jira] [Created] (KAFKA-20454) Verify that `bin/kafka-consumer-groups.sh --reset-offsets` fails for "streams" group Matthias J. Sax (Jira)
• [PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka] via GitHub
  • Re: [PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka] via GitHub
  • Re: [PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka] via GitHub
  • Re: [PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20441) Follow ups for KIP-1066 Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-20445) Clarify that empty array implies no changes for logDirs in metadata change record Chia-Ping Tsai (Jira)
• [PR] MINOR: increase test visibility to public in client integration tests. [kafka] via GitHub
  • Re: [PR] MINOR: increase test visibility to public in client integration tests. [kafka] via GitHub
• [jira] [Commented] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Kartikay Dubey (Jira)
  • [jira] [Commented] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Kartikay Dubey (Jira)
• [jira] [Assigned] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Kartikay Dubey (Jira)
  • [jira] [Assigned] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Kartikay Dubey (Jira)
• [jira] [Assigned] (KAFKA-20364) Remove control records reads from metadata module Jun Cho (Jira)
• [jira] [Assigned] (KAFKA-20429) Review async consumer single background queue design sanghyeok An (Jira)
• [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
  • Re: [PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka] via GitHub
• [PR] MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide [kafka] via GitHub
  • Re: [PR] MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide [kafka] via GitHub
  • Re: [PR] MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide [kafka] via GitHub
  • Re: [PR] MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide [kafka] via GitHub
• [PR] MINOR: Remove -SNAPSHOT in version.py [kafka] via GitHub
  • Re: [PR] MINOR: Remove -SNAPSHOT in version.py [kafka] via GitHub
• [PR] KAFKA-20085 Replace verbose version instructions with updateVersion task [kafka] via GitHub
  • Re: [PR] KAFKA-20085 Replace verbose version instructions with updateVersion task [kafka] via GitHub
  • Re: [PR] KAFKA-20085 Replace verbose version instructions with updateVersion task [kafka] via GitHub
• [jira] [Commented] (KAFKA-20302) Receive buffers allocated from MemoryPool may not be released if request is invalid Edoardo Comar (Jira)
• [jira] [Created] (KAFKA-20453) Metrics of group "kafka.network.SocketServer" should have tags unique to each SocketServer Edoardo Comar (Jira)
• [jira] [Updated] (KAFKA-20085) Let's replace this verbose instruction with a custom Gradle task PoAn Yang (Jira)
• [jira] [Resolved] (KAFKA-15433) Follower fetch from tiered offset Kamal Chandraprakash (Jira)
• [jira] [Resolved] (KAFKA-20442) Consumer/Share/Streams group assignment epoch is not updated when the last member leaves David Jacot (Jira)
• [jira] [Updated] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 Roland Sommer (Jira)
• [jira] [Commented] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol Himanshu Pandey (Jira)
• Re: [PR] Fix high-watermark metric returning -1 for leader [kafka] via GitHub
• Re: [PR] Strategy based implementation of acquire mode in SharePartition [kafka] via GitHub
• Re: [PR] KAFKA−17999: Fix flaky test DynamicConnectionQuotaTest.testDynamicConnectionQuota [kafka] via GitHub
  • Re: [PR] KAFKA−17999: Fix flaky test DynamicConnectionQuotaTest.testDynamicConnectionQuota [kafka] via GitHub
• Re: [PR] KAFKA-19663: kafka-broker-api tool should support to get controller api version [kafka] via GitHub
• Re: [PR] KAFKA-19070: add taskId to consumer override clientId [kafka] via GitHub
  • Re: [PR] KAFKA-19070: add taskId to consumer override clientId [kafka] via GitHub
• Re: [PR] MINOR: Enable auth test for new consumer [kafka] via GitHub
  • Re: [PR] MINOR: Enable auth test for new consumer [kafka] via GitHub
• Re: [PR] KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-15709) KRaft support in ServerStartupTest Oscar Arismendi (Jira)
• [jira] [Commented] (KAFKA-15709) KRaft support in ServerStartupTest Oscar Arismendi (Jira)
• [PR] MINOR: add comma before "and" in README (for test the upload of gradle report when jdk version is different between trunk and 41) [kafka] via GitHub
  • Re: [PR] MINOR: add comma before "and" in README (for test the upload of gradle report when jdk version is different between trunk and 41) [kafka] via GitHub
  • Re: [PR] MINOR: add comma before "and" in README [kafka] via GitHub
  • Re: [PR] MINOR: add comma before "and" in README [kafka] via GitHub
• [PR] MINOR: add comma before "and" in README (for test the upload of gradle report when jdk version is different between trunk and 40) [kafka] via GitHub
  • Re: [PR] MINOR: add comma before "and" in README (for test the upload of gradle report when jdk version is different between trunk and 40) [kafka] via GitHub
  • Re: [PR] MINOR: add comma before "and" in README (for test the upload of gradle report when jdk version is different between trunk and 40) [kafka] via GitHub
• [PR] [Test] the upload of gradle report when jdk version is different between trunk and 40 [kafka] via GitHub
  • Re: [PR] [Test] the upload of gradle report when jdk version is different between trunk and 40 [kafka] via GitHub
  • Re: [PR] [Test] the upload of gradle report when jdk version is different between trunk and 40 [kafka] via GitHub
• [PR] KAFKA-19768: test on 4.3 [kafka] via GitHub
  • Re: [PR] KAFKA-19768: test on 4.3 [kafka] via GitHub
  • Re: [PR] KAFKA-19768: test on 4.3 [kafka] via GitHub
• Re: [PR] KAFKA-17076: retain last batch in each round of cleaning [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19649) Document List Offset changes in upgrade.html Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20445) Clarify that empty array implies no changes for logDirs in metadata change record Chia-Ping Tsai (Jira)
• [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka] via GitHub
• [jira] [Closed] (KAFKA-20165) Consumer poll may fail with unrecoverable KafkaException if topic not in metadata when fetching committed offsets Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-19768) `ci-complete` needs to work with active branches after the JDK is updated Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-19768: Update ci-complete to support branch 4.0 buildscan upload [kafka] via GitHub
• [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
  • Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
  • Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
  • Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
  • Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
• [PR] MINOR: Clarify docs for consumer leave options & rebalances [kafka] via GitHub
  • Re: [PR] MINOR: Clarify docs for consumer leave options & rebalances [kafka] via GitHub
• [jira] [Commented] (KAFKA-13499) Avoid restoring outdated records Matthias J. Sax (Jira)
• [PR] MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test classes [kafka] via GitHub
  • Re: [PR] MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test classes [kafka] via GitHub
  • Re: [PR] MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test classes [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key Lucy Liu (Jira)
• [jira] [Resolved] (KAFKA-20447) Native image contains CVE-2026-22184 in zlib Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20446) Native image contains CVE-2026-28390 in libcrypto3 and libssl3 Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20451) Move RequestChannel Responses to server module Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-20443) Move RequestChannel Requests to server module Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-20449) OffsetFetcherUtils.updateSubscriptionState logs at WARN for benign race condition during rebalance Lianet Magrans (Jira)
• [jira] [Assigned] (KAFKA-20449) OffsetFetcherUtils.updateSubscriptionState logs at WARN for benign race condition during rebalance Lianet Magrans (Jira)
• [jira] [Commented] (KAFKA-20314) Segmentation fault when starting kafka-native Devin Smith (Jira)
  • [jira] [Commented] (KAFKA-20314) Segmentation fault when starting kafka-native Szabolcs Stremler (Jira)
• [jira] [Created] (KAFKA-20450) SafeObjectInputStream uses denylist based approach Subbu (Jira)
• [PR] KAFKA-20450 : Fix : Use Allowlist for SafeObjectInputStream than denylist [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
  • Re: [PR] KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream [kafka] via GitHub
• [PR] KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG [kafka] via GitHub
  • Re: [PR] KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG [kafka] via GitHub
• [jira] [Created] (KAFKA-20449) OffsetFetcherUtils.updateSubscriptionState logs at WARN for benign race condition during rebalance Tamas Kornai (Jira)
• [PR] KAFKA-20448: Fix Docker JVM image build when using local kafka archive [kafka] via GitHub
• [jira] [Updated] (KAFKA-20448) Docker image build fails with --image-type=jvm and --kafka-archive Szabolcs Stremler (Jira)
  • [jira] [Updated] (KAFKA-20448) Docker image build fails with --image-type=jvm and --kafka-archive Szabolcs Stremler (Jira)
  • [jira] [Updated] (KAFKA-20448) Docker image build fails with --image-type=jvm and --kafka-archive Szabolcs Stremler (Jira)
  • [jira] [Updated] (KAFKA-20448) Docker image build fails with --image-type=jvm and --kafka-archive Szabolcs Stremler (Jira)
• [jira] [Created] (KAFKA-20448) Docker image build fails with --image-type=jvm and --kafka-archive Szabolcs Stremler (Jira)
• Re: [PR] KAFKA-20252 Migrate clearYammerMetrics to TestUtils [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-20447) Native image contains CVE-2026-22184 in zlib PoAn Yang (Jira)
• [PR] KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 [kafka] via GitHub
  • Re: [PR] KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 [kafka] via GitHub
  • Re: [PR] KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 [kafka] via GitHub
  • Re: [PR] KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20446) Native image contains CVE-2026-28390 in libcrypto3 and libssl3 PoAn Yang (Jira)
• [jira] [Updated] (KAFKA-20447) Native image contains CVE-2026-22184 in zlib PoAn Yang (Jira)
• [PR] MINOR: Move AbstractIterator, CircularIterator, CloseableIterator, CopyOnWriteMap, FixedOrderMap, PrimitiveRef into internal package [kafka] via GitHub
  • Re: [PR] MINOR: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterator... into internal [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect Daeho Kwon (Jira)
• [PR] KAFKA-20437: Fix ssl.enabled.protocols dynamic reconfiguration not being applied [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20445) Allow clearing logDirs in BrokerRegistrationChangeRecord by supporting null default values Ming-Yen Chung (Jira)
• [jira] [Created] (KAFKA-20447) Native image contains CVE-2026-22184 in zlib PoAn Yang (Jira)
• [jira] [Created] (KAFKA-20446) Native image contains CVE-2026-28390 in libcrypto3 and libssl3 PoAn Yang (Jira)
• [jira] [Created] (KAFKA-20444) Align TxnOffsetCommit API with OffsetCommit API (KIP-1319) David Jacot (Jira)
• [jira] [Created] (KAFKA-20445) Allow clearing logDirs in BrokerRegistrationChangeRecord by supporting null default values Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-20025: enable dynamic TLS reconfiguration for KafkaRaftManager [kafka] via GitHub
  • Re: [PR] KAFKA-20025: enable dynamic TLS reconfiguration for KafkaRaftManager [kafka] via GitHub
• [PR] Add OpenLineage extension for Kafka Connect [kafka] via GitHub
  • Re: [PR] Add OpenLineage extension for Kafka Connect [kafka] via GitHub
• [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka] via GitHub
  • Re: [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka] via GitHub

• Earlier messages