jira
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/09/03
[PR] MINOR: Document plugin-storage cleanup after removing the plugin or downgrading [kafka]
via GitHub
2026/09/03
[jira] [Commented] (KAFKA-20916) message protocol document missing new control record types
Ken Huang (Jira)
2026/09/03
[jira] [Commented] (KAFKA-20354) Add missing Control Batch types in documentation
Ken Huang (Jira)
2026/09/03
[jira] (KAFKA-20354) Add missing Control Batch types in documentation
Ken Huang (Jira)
2026/09/03
[jira] [Updated] (KAFKA-20354) Add missing Control Batch types in documentation
Ken Huang (Jira)
2026/09/03
[jira] [Updated] (KAFKA-20354) Add missing Control Batch types in documentation
Ken Huang (Jira)
2026/09/03
[jira] [Resolved] (KAFKA-20916) message protocol document missing new control record types
Ken Huang (Jira)
2026/09/03
Re: [PR] KAFKA-20916: Backport KAFKA-20354 to 4.3 [kafka]
via GitHub
2026/09/03
[jira] [Commented] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time
sanghyeok An (Jira)
2026/09/03
[jira] [Assigned] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time
sanghyeok An (Jira)
2026/09/03
[jira] [Updated] (KAFKA-20936) Bump lz4 to 1.11.2
Apoorv Mittal (Jira)
2026/09/03
[jira] [Updated] (KAFKA-20840) Bump jetty to 12.0.37
Apoorv Mittal (Jira)
2026/09/03
[jira] [Commented] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154)
Mickael Maison (Jira)
2026/09/03
[jira] [Updated] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4]
Apoorv Mittal (Jira)
2026/09/03
Re: [PR] KAFKA-20936: Bump lz4-java to 1.11.2 [kafka]
via GitHub
2026/09/03
Re: [PR] KAFKA-20840: Bump jetty to 12.0.37 [kafka]
via GitHub
2026/09/03
Re: [PR] KAFKA-21007: Migrate BrokerTopicStats test cases to BrokerTopicMetricsTest [kafka]
via GitHub
2026/09/03
[PR] KAFKA-20916: Backport KAFKA-20354 to 4.3 [kafka]
via GitHub
2026/09/03
Re: [PR] KAFKA-17840: Move QuotaFactory to server module [kafka]
via GitHub
2026/09/03
[jira] [Commented] (KAFKA-19327) MM2 Source Connector Fails at Scale
Doyeon Kim (Jira)
2026/09/03
[jira] [Assigned] (KAFKA-19327) MM2 Source Connector Fails at Scale
Doyeon Kim (Jira)
2026/09/03
Re: [PR] KAFKA-20609 : Use lastModified time as retention anchor for future-timestamped segments [kafka]
via GitHub
2026/09/03
Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka]
via GitHub
2026/09/03
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/03
Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka]
via GitHub
2026/09/03
[PR] MINOR: Replace Collections.singleton() with Set.of() in ConfigCommand [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20665: Add a lag-driven assignment refiner for testing [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20665: Add a lag-driven assignment refiner for testing [kafka]
via GitHub
2026/09/02
[PR] KAFKA-21014: Fix flaky testAdminRebootstrapDisabled and testAdminRebootstrap [kafka]
via GitHub
2026/09/02
[PR] KAFKA-20665: Add a lag-driven assignment refiner for testing [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-21017: Deflake ConsumerGroupCommandSaslAuthenticationTest [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-18744: reuse LoginCallbackHandler on Kerberos re-login [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20985) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol
Gavin Wang (Jira)
2026/09/02
[jira] [Updated] (KAFKA-20985) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol
Gavin Wang (Jira)
2026/09/02
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21026) Design JHM benchmark for "refiner"
Gavin Wang (Jira)
2026/09/02
Re: [PR] KAFKA-20993: Remove hamcrest from org.apache.kafka.streams.processor.internals.assignment [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time
Sean Quah (Jira)
2026/09/02
Re: [PR] KAFKA-20981: fail on an unknown status code in the Streams heartbeat response [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context
Ken Huang (Jira)
2026/09/02
Re: [PR] KAFKA-20665: Make the assignment refiner injectable [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context
Ken Huang (Jira)
2026/09/02
[PR] KAFKA-21025: StreamsGroupHeartbeatRequest must drop warmup tasks for v0 [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Ken Huang (Jira)
2026/09/02
[PR] MINOR: Remove stale flaky annotation for resolved KAFKA-15914 [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka]
via GitHub
2026/09/02
[jira] [Assigned] (KAFKA-21024) WindowToTimestampedWindowByteStoreAdapter.query() does not convert results to timestamped format
Hrishi Baskaran (Jira)
2026/09/02
[jira] [Assigned] (KAFKA-21025) StreamsGroupHeartbeatRequest.Builder does not clear owned warm-up tasks when it negotiates request version 0
Matthias J. Sax (Jira)
2026/09/02
[jira] [Created] (KAFKA-21025) StreamsGroupHeartbeatRequest.Builder does not clear owned warm-up tasks when it negotiates request version 0
Matthias J. Sax (Jira)
2026/09/02
[jira] [Commented] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time
sanghyeok An (Jira)
2026/09/02
Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-15853: [2/N] Move bulk of remaining configs to AbstractKafkaConfig [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-17840: Move QuotaFactory to server module [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-15853: [2/N] Move bulk of remaining configs to AbstractKafkaConfig [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
2026/09/02
[jira] [Resolved] (KAFKA-20941) Replace HTMLTestRunner
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-20941: Replace HTMLTestRunner with pytest-html [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-21020: Upgrade jline from 3.30.16 to 4.2.1 [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
[jira] [Resolved] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py`
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21024) WindowToTimestampedWindowByteStoreAdapter.query() does not convert results to timestamped format
Ziyun Fu (Jira)
2026/09/02
Re: [PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21024) WindowToTimestampedWindowByteStoreAdapter.query() does not convert results to timestamped format
Ziyun Fu (Jira)
2026/09/02
[jira] [Created] (KAFKA-21024) WindowToTimestampedWindowByteStoreAdapter.query() does not convert results to timestamped format
Ziyun Fu (Jira)
2026/09/02
Re: [PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20981: fail on an unknown status code in the Streams heartbeat response [kafka]
via GitHub
2026/09/02
[jira] [Assigned] (KAFKA-21023) Improve the dependency-check configuration
dino2895 (Jira)
2026/09/02
Re: [PR] KAFKA-20416: Source changelog committed offset retry [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20416: Source changelog committed offset retry [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-21001: Keep warm-up tasks sticky in the streams sticky assignor [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21023) Improve the dependency-check configuration
Chia-Ping Tsai (Jira)
2026/09/02
[jira] [Created] (KAFKA-21023) Improve the usage of dependencycheck
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-21001: Keep warm-up tasks sticky in the streams sticky assignor [kafka]
via GitHub
2026/09/02
[jira] [Assigned] (KAFKA-20579) Implement dynamic allocation for compressed data
Evan Zhou (Jira)
2026/09/02
Re: [PR] KAFKA-20981: fail on an unknown status code in the Streams heartbeat response [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20416: Source changelog committed offset retry [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20960 - Block ZK-to-KRaft migration finalization until brokers re-register [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20790: adding assignor broker side validation [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20790: adding assignor broker side validation [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance
Lianet Magrans (Jira)
2026/09/02
[PR] KAFKA-20097: Return topic ID when a topic already exists [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21022) Broker Crash During ZK-to-KRaft Migration Due to Missing Topic ID in Empty Log Directory
Youssef Ismail (Jira)
2026/09/02
Re: [PR] MINOR: Deflake ConsumerGroupCommandSaslAuthenticationTest by polling during group-visibility wait [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20790: adding assignor broker side validation [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21022) Broker Crash During ZK-to-KRaft Migration Due to Missing Topic ID in Empty Log Directory
Youssef Ismail (Jira)
2026/09/02
Re: [PR] KAFKA-20985: Keep static member id when LeaveGroup is suppressed [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20985: Keep static member id when LeaveGroup is suppressed [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-17777: Flaky KafkaConsumerTest testReturnRecordsDuringRebalance [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20985: Keep static member id when LeaveGroup is suppressed [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Matthias J. Sax (Jira)
2026/09/02
[jira] [Commented] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context
Matthias J. Sax (Jira)
2026/09/02
[jira] [Commented] (KAFKA-20416) RocksDB loses entries during broker patches.
Bill Bejeck (Jira)
2026/09/02
[jira] [Assigned] (KAFKA-20416) RocksDB loses entries during broker patches.
Bill Bejeck (Jira)
2026/09/02
[PR] KAFKA-20416: Source changelog committed offset retry [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
2026/09/02
Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka]
via GitHub
2026/09/02
[jira] [Resolved] (KAFKA-20952) Remove hamcrest from org.apache.kafka.streams.kstream package
Ken Huang (Jira)
2026/09/02
Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/02
[PR] KAFKA-20960 - Block ZK-to-KRaft migration finalization until brokers re-register [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Fix occasional OOM in FetcherTest [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21018) Broken links in Kafka docs and javadocs
Jira
2026/09/02
Re: [PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Move SaslClientsWithInvalidCredentialsTest to clients integration tests [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-18771: Retry describeMetadataQuorum in flaky test [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-18771: Retry describeMetadataQuorum in flaky test [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20985: Keep static member id when LeaveGroup is suppressed [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20941: Replace HTMLTestRunner with pytest-html [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time
Sean Quah (Jira)
2026/09/02
Re: [PR] MINOR: Avoid O(n) List.contains() in AbstractStickyAssignor isBalanced [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time.
Sean Quah (Jira)
2026/09/02
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Move SaslClientsWithInvalidCredentialsTest to clients integration tests [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-20936) Bump lz4 to 1.11.2
Chia-Ping Tsai (Jira)
2026/09/02
[PR] KAFKA-21002: [1/2] Remove hamcrest from org.apache.kafka.streams package [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-21020: Upgrade jline from 3.30.16 to 4.2.1 [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20985: Keep static member id when LeaveGroup is suppressed [kafka]
via GitHub
2026/09/02
[jira] [Resolved] (KAFKA-20507) Clarify consumer docs around commits without metadata & invalid position handling
TengYao Chi (Jira)
2026/09/02
Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20507: Document impact of committing offsets without a leader epoch [kafka]
via GitHub
2026/09/02
[jira] [Updated] (KAFKA-21020) Fix CVE-2026-56740: Upgrade jline from 3.30.16 to 4.2.1
Shubhi Gupta (Jira)
2026/09/02
[PR] KAFKA-21020: Upgrade jline from 3.30.16 to 4.2.1 [kafka]
via GitHub
2026/09/02
[PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20735: Skip state-directory lock on close when there are no sto… [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-21018) Broken links in Kafka docs and javadocs
ASF GitHub Bot (Jira)
2026/09/02
[jira] [Assigned] (KAFKA-21019) Cover consumer and share group protocols in docker sanity tests
majialong (Jira)
2026/09/02
[jira] [Created] (KAFKA-21020) Fix CVE-2026-56740: Upgrade jline from 3.30.16 to 4.2.1
Shubhi Gupta (Jira)
2026/09/02
Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka]
via GitHub
2026/09/02
[jira] [Assigned] (KAFKA-21017) Fix flaky ConsumerGroupCommandSaslAuthenticationTest
dino2895 (Jira)
2026/09/02
Re: [PR] KAFKA-20978: Add consumer group protocol test cases to benchmark_test.py [kafka]
via GitHub
2026/09/02
[PR] MINOR: Lower log level for non-fatal metadata update failures in AdminMetadataManager [kafka]
via GitHub
2026/09/02
[PR] KAFKA-21018: fix broken links [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21019) Cover consumer and share group protocols in docker sanity tests
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-20941: Replace HTMLTestRunner with pytest-html [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21018) Broken links in Kafka docs and javadocs
Jira
2026/09/02
Re: [PR] KAFKA-18771: Retry describeMetadataQuorum in flaky test [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20941: Replace HTMLTestRunner with pytest-html [kafka]
via GitHub
2026/09/02
Re: [PR] MINOR: Additional cleanup in AlterConfigs [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-18771: Retry describeMetadataQuorum in flaky test [kafka]
via GitHub
2026/09/02
[PR] KAFKA-21016: Add client quota-utilization metrics (KIP-1373) [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21017) Fix flaky ConsumerGroupCommandSaslAuthenticationTest
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] MINOR: Avoid O(n) List.contains() in AbstractStickyAssignor isBalanced [kafka]
via GitHub
2026/09/02
Re: [PR] Add OpenLineage extension for Kafka Connect [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20609 : Use lastModified time as retention anchor for future-timestamped segments [kafka]
via GitHub
2026/09/02
[jira] [Commented] (KAFKA-20971) Add cross version system test for "streams" static group membership
Lucas Brutschy (Jira)
2026/09/02
[jira] [Resolved] (KAFKA-21003) `testValidCreateTopicsRequests` should verify replica assignments of created topics
Chia-Ping Tsai (Jira)
2026/09/02
Re: [PR] KAFKA-21003: Verify replica assignments in CreateTopicsRequestTest [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka]
via GitHub
2026/09/02
Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka]
via GitHub
2026/09/02
[PR] KAFKA-21007: Migrate BrokerTopicStats test cases to BrokerTopicMetricsTest [kafka]
via GitHub
2026/09/02
[jira] [Created] (KAFKA-21016) Add quota-utilization metric for client quotas
Manan Gupta (Jira)
2026/09/01
[jira] [Commented] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods
Aditya Kousik (Jira)
2026/09/01
Re: [PR] KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows [kafka]
via GitHub
2026/09/01
[PR] MINOR: Additional cleanup in AlterConfigs [kafka]
via GitHub
2026/09/01
Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka]
via GitHub
2026/09/01
[jira] [Created] (KAFKA-21015) Refactor producer control-record appends to use a single log append
Hrishi Baskaran (Jira)
2026/09/01
Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka]
via GitHub
2026/09/01
Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka]
via GitHub
2026/09/01
Re: [PR] KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows [kafka]
via GitHub
2026/09/01
Re: [PR] MINOR: Stable flaky e2e test `share_consumer_dlq_tiered_storage_test` (WIP) [kafka]
via GitHub
2026/09/01
Re: [PR] MINOR: Reject frame version, type and version varints that decode negative [kafka]
via GitHub
2026/09/01
Re: [PR] KAFKA-15976: Allow specifying initial offsets while creating connectors [kafka]
via GitHub
2026/09/01
Re: [PR] MINOR: make Utils.humanReadableByteCount thread-safe via ThreadLocal DecimalFormat [kafka]
via GitHub
2026/09/01
[jira] (KAFKA-4587) Rethink Unification of Caching with Dedupping
Hrishi Baskaran (Jira)
2026/09/01
[jira] [Assigned] (KAFKA-4587) Rethink Unification of Caching with Dedupping
Hrishi Baskaran (Jira)
2026/09/01
[jira] [Commented] (KAFKA-4587) Rethink Unification of Caching with Dedupping
Hrishi Baskaran (Jira)
2026/09/01
[jira] [Assigned] (KAFKA-4587) Rethink Unification of Caching with Dedupping
Hrishi Baskaran (Jira)
2026/09/01
[PR] MINOR: Avoid O(n) List.contains() in AbstractStickyAssignor isBalanced [kafka]
via GitHub
2026/09/01
Re: [PR] fix(utils): make humanReadableByteCount thread-safe via ThreadLocal DecimalFormat [kafka]
via GitHub
Earlier messages
Later messages