Messages by Thread
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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] [Created] (KAFKA-20450) SafeObjectInputStream uses denylist based approach
Subbu (Jira)
-
[PR] KAFKA-20450 : Fix : Use Allowlist for SafeObjectInputStream than denylist [kafka]
via GitHub
-
[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] [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
-
[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
-
[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
-
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
-
Re: [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20443) Move RequestChannel Requests/Responses to server module
Chia-Ping Tsai (Jira)
-
[PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20443) Move RequestChannel Requests/Responses to server module
Mickael Maison (Jira)
-
[PR] KAFKA-20442: Update streams group assignment epoch when last member leaves [kafka]
via GitHub
-
[PR] KAFKA-20442: Update consumer group assignment epoch when last member leaves [kafka]
via GitHub
-
[PR] KAFKA-20442: Update share group assignment epoch when last member leaves [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20442) Consumer/Share/Streams group assignment epoch is not updated when the last member leaves
David Jacot (Jira)
-
[jira] [Created] (KAFKA-20441) Follow ups for KIP-1066
Mickael Maison (Jira)
-
[PR] MINOR: add clear description on torgdor [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"
Shashank (Jira)
-
Re: [PR] KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" [kafka]
via GitHub
-
Re: [PR] MINOR Clarified maximum length of COMPACT_STRING [kafka]
via GitHub
-
Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka]
via GitHub
-
[jira] [Reopened] (KAFKA-13499) Avoid restoring outdated records
Matthias J. Sax (Jira)
-
[jira] [Comment Edited] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Jira
-
[PR] MINOR: fix incorrect JavaDocs for headers-stores [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-10844) groupBy without shuffling
Guang Zhao (Jira)
-
[jira] [Assigned] (KAFKA-15709) KRaft support in ServerStartupTest
Oscar Arismendi (Jira)
-
[jira] [Assigned] (KAFKA-20439) Allow to write dropped records in the DLQ
Daeho Kwon (Jira)
-
[jira] [Commented] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
-
[jira] [Assigned] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
-
[jira] [Comment Edited] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Daeho Kwon (Jira)
-
[PR] Bump pytest from 8.3.3 to 9.0.3 in /tests [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Daeho Kwon (Jira)
-
[jira] [Commented] (KAFKA-20439) Allow to write dropped records in the DLQ
Daeho Kwon (Jira)
-
[jira] [Updated] (KAFKA-20440) PEM certificate support should not depend on PKCS12
Jakub Scholz (Jira)
-
[PR] KAFKA-20440: Use default Keystore type instead of hardcoding PKCS12 keystore type [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20440) PEM certificate support should not depend on PKCS12
Jakub Scholz (Jira)
-
[jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams
Matthias J. Sax (Jira)
-
Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20213) Review assignment updates in ShareConsumer from background reconciliations
Lianet Magrans (Jira)
-
[jira] [Assigned] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found
Lianet Magrans (Jira)
-
[PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20439) Allow to write dropped records in the DLQ
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20438) Allow dropping "future" records
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20438) Allow dropping "future" records
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Jakub Scholz (Jira)
-
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
-
[PR] MINOR: Clarify group.consumer.assignors doc about default assignor change [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20275) API to set commit offsets without being subscribed
Kirk True (Jira)
-
[jira] [Assigned] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Lianet Magrans (Jira)
-
[jira] [Resolved] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with different assignor
David Jacot (Jira)
-
[jira] [Assigned] (KAFKA-13248) Class name mismatch for LoggerFactory.getLogger method in TimeOrderedWindowStoreBuilder.java
Evan Zhou (Jira)
-
[jira] [Assigned] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult
Evan Zhou (Jira)
-
[jira] [Assigned] (KAFKA-19688) Provide clean upgrade path from transformValues to processValues
TengYao Chi (Jira)
-
[jira] [Commented] (KAFKA-17178) Update KTable.transformValues to new Processor API
TengYao Chi (Jira)
-
[jira] [Assigned] (KAFKA-17178) Update KTable.transformValues to new Processor API
TengYao Chi (Jira)
-
[PR] KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… [kafka]
via GitHub