Messages by Date
-
2026/02/18
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19976: Deprecate streams-scala module [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. (#21448) [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. (#21448) [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Implement TODOs to use StreamTask and StandbyTask whenever it's possible. [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-16836: Fix incorrect suspend reason in standby update listener [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20158: Adding MeteredSessionStore and tests [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20158: Adding interfaces for headers in session store [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests [kafka]
via GitHub
-
2026/02/18
[jira] [Created] (KAFKA-20195) Better offset reset functionality for the new consumer group rebalance protocol
Levani Kokhreidze (Jira)
-
2026/02/18
Re: [PR] MINOR: Implement TODOs to use StreamTask and StandbyTask whenever it's possible. [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20159: Group configuration for share.delivery.count.limit [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Implement TODOs to use StreamTask and StandbyTask whenever it's possible. [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20092 buildscript and project dependencies version updates [kafka]
via GitHub
-
2026/02/18
[jira] [Updated] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project)
Jira
-
2026/02/18
[jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Matthias J. Sax (Jira)
-
2026/02/18
[jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Matthias J. Sax (Jira)
-
2026/02/18
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20173: Propagate headers into serde 2/N [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20165 [2]: Integration tests to validate different OffsetFetch response behaviour on topic deleted [kafka]
via GitHub
-
2026/02/18
[jira] [Resolved] (KAFKA-14579) Move DumpLogSegments to tools
Mickael Maison (Jira)
-
2026/02/18
Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
-
2026/02/18
[PR] KAFKA-20066: Assignment epochs for consumer groups [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (4/N) [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Use more appropriate exception when validate builder parameters [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19963: Add more information to doc to explain how to parallelize per topic with Kafka Streams [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19915: [1/3] Move LogAppendResult to server module [kafka]
via GitHub
-
2026/02/18
[jira] [Resolved] (KAFKA-20152) Remove unused CoordinatorMetrics#registry
Chia-Ping Tsai (Jira)
-
2026/02/18
Re: [PR] KAFKA-20152: Remove unused CoordinatorMetrics#registry [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19976: Deprecate streams-scala module [kafka]
via GitHub
-
2026/02/18
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
-
2026/02/18
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Move ProducerIntegrationTest to clients-integration-tests and rewrite in Java [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Move ProducerIntegrationTest to clients-integration-tests and rewrite in Java [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
[jira] [Comment Edited] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
2026/02/18
[jira] [Resolved] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
2026/02/18
Re: [PR] KAFKA-20168: Upgrade Jetty from 9.4.57 to 9.4.58 to fix CVE-2025-5115 (3.9) [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19144 Move DelayedProduce to server module [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20137: Add javadoc to public APIs in org.apache.kafka.clients.producer [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
Re: [PR] Add test scale up controller with "initial controllers" formatting [kafka]
via GitHub
-
2026/02/18
[PR] Add test scale up controller with "initial controllers" formatting [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
-
2026/02/18
[jira] [Resolved] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Andrew Schofield (Jira)
-
2026/02/18
Re: [PR] KAFKA-20137: Add javadoc to public APIs in org.apache.kafka.clients.producer [kafka]
via GitHub
-
2026/02/18
[jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
2026/02/18
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
-
2026/02/18
[jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
2026/02/18
[jira] [Assigned] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
2026/02/18
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
-
2026/02/18
[jira] [Created] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
2026/02/18
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Add 4.2.0 to the CVE Scanner [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20152: Remove unused CoordinatorMetrics#registry [kafka]
via GitHub
-
2026/02/18
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/18
[jira] [Commented] (KAFKA-20090) TV2 can allow for ongoing transactions with max epoch that never complete
sanghyeok An (Jira)
-
2026/02/18
[PR] KAFKA-20090: rotate producerId when epoch exhausted during transaction completion. [kafka]
via GitHub
-
2026/02/18
Re: [PR] MINOR: Avoid repeated logger creation in InternalTopicManager [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20159: Group configuration for share.delivery.count.limit [kafka]
via GitHub
-
2026/02/17
[jira] [Comment Edited] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Ken Huang (Jira)
-
2026/02/17
Re: [PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Ken Huang (Jira)
-
2026/02/17
[PR] KAFKA-20168: Upgrade Jetty from 9.4.57 to 9.4.58 to fix CVE-2025-5115 (3.9) [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
2026/02/17
[jira] [Updated] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
2026/02/17
Re: [PR] MINOR: Fix JDK version and architecture parameters in system test worker provisioning [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Fix lost custom error message in CoordinatorPartitionWriter#append [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Use a separate map to store acknowledgements in ShareAcknowledgementEvent. [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19881: change CVE scanner workflow to run on active branches (wip) [kafka]
via GitHub
-
2026/02/17
Re: [PR] Offset handling, data loss, fault tolerance added [kafka]
via GitHub
-
2026/02/17
Re: [PR] Offset handling, data loss, fault tolerance added [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP] [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19915: [1/3] Move LogAppendResult to server module [kafka]
via GitHub
-
2026/02/17
[PR] KAFKA-20152: Remove unused CoordinatorMetrics#registry [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
2026/02/17
[PR] Minor improve rocksdb test [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20137: Add javadoc to public APIs in org.apache.kafka.clients.producer [kafka]
via GitHub
-
2026/02/17
[PR] MINOR: Implement TODOs to use StreamTask and StandbyTask whenever it's possible. [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
[jira] [Comment Edited] (KAFKA-17789) State updater stuck when starting with empty state folder
Nikita Shupletsov (Jira)
-
2026/02/17
Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-17789) State updater stuck when starting with empty state folder
Nikita Shupletsov (Jira)
-
2026/02/17
Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka]
via GitHub
-
2026/02/17
[jira] [Updated] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Matthias J. Sax (Jira)
-
2026/02/17
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
-
2026/02/17
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
-
2026/02/17
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
-
2026/02/17
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. (#21448) [kafka]
via GitHub
-
2026/02/17
[PR] MINOR: rename TaskRegistry methods to better reflect their purpose. (#21448) [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-19863) Add documentation on how to implement a custom exception handler
Nikita Shupletsov (Jira)
-
2026/02/17
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (4/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (3/N) [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Chia-Ping Tsai (Jira)
-
2026/02/17
[PR] KAFKA-16836: Fix incorrect suspend reason in standby update listener [kafka]
via GitHub
-
2026/02/17
[jira] [Assigned] (KAFKA-16836) Suspend reason of standby update listener is not correct
Lucas Brutschy (Jira)
-
2026/02/17
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka]
via GitHub
-
2026/02/17
[jira] [Created] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Alieh Saeedi (Jira)
-
2026/02/17
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (4/N) [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20184) jose4j marked as compileOnly in clients module causes ClassNotFoundException at runtime for OAuth authentication
Kirk True (Jira)
-
2026/02/17
[jira] [Commented] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Kirk True (Jira)
-
2026/02/17
[jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Kirk True (Jira)
-
2026/02/17
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20013) Convert docs to Markdown
Kirk True (Jira)
-
2026/02/17
[jira] [Commented] (KAFKA-19863) Add documentation on how to implement a custom exception handler
Rajarshi Misra (Jira)
-
2026/02/17
[jira] [Assigned] (KAFKA-19863) Add documentation on how to implement a custom exception handler
Rajarshi Misra (Jira)
-
2026/02/17
[jira] [Assigned] (KAFKA-19650) Add message key to org.apache.kafka.clients.producer.RecordMetadata
Rajarshi Misra (Jira)
-
2026/02/17
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (3/N) [kafka]
via GitHub
-
2026/02/17
[jira] [Closed] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Mikael Carlstedt (Jira)
-
2026/02/17
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (4/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka]
via GitHub
-
2026/02/17
[jira] [Assigned] (KAFKA-20192) Brittle logic in ReconfigurableQuorumIntegrationTest
Dmitry Werner (Jira)
-
2026/02/17
[PR] MINOR: Fix lost custom error message in CoordinatorPartitionWriter#append [kafka]
via GitHub
-
2026/02/17
[jira] [Created] (KAFKA-20192) Brittle logic in ReconfigurableQuorumIntegrationTest
Mickael Maison (Jira)
-
2026/02/17
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (3/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
-
2026/02/17
Re: [PR] 4.2 docs [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Matthias J. Sax (Jira)
-
2026/02/17
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/17
[PR] 4.2 docs [kafka]
via GitHub
-
2026/02/17
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (5/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19915: [1/3] Move LogAppendResult to server module [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Mikael Carlstedt (Jira)
-
2026/02/17
[jira] [Commented] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Nikita Shupletsov (Jira)
-
2026/02/17
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-17251: Avoid WARN on cleanup when state directory only contains process metadata. [kafka]
via GitHub
-
2026/02/17
[jira] [Commented] (KAFKA-20106) Improve behaviour of consumer assignment API under async reconciliations
Lianet Magrans (Jira)
-
2026/02/17
Re: [PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/17
[PR] MINOR: Move ProducerIntegrationTest to clients-integration-tests and rewrite in Java [kafka]
via GitHub
-
2026/02/17
[PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (3/N) [kafka]
via GitHub
-
2026/02/17
[jira] [Resolved] (KAFKA-17302) ReplicaFetcher changes for fetching from tiered offset
Kamal Chandraprakash (Jira)
-
2026/02/17
[jira] [Updated] (KAFKA-15433) Follower fetch from tiered offset
Kamal Chandraprakash (Jira)
-
2026/02/17
Re: [PR] KAFKA-17302: ReplicaFetcher changes for fetching from tiered offset [kafka]
via GitHub
-
2026/02/17
[PR] KAFKA-18046: Avoid repeated logger creation in InternalTopicManager [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20159: Group configuration for share.delivery.count.limit [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
-
2026/02/17
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (4/N) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-8958 : Fix Kafka Streams JavaDocs with regard to used Serdes [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-18896 add KIP-877 support for Login [kafka]
via GitHub
-
2026/02/17
Re: [PR] MINOR: Remove Evolving annotation from GroupState [kafka]
via GitHub
-
2026/02/17
[PR] MINOR: Rename ConfiguredTopology to TopologyValidationResult [kafka]
via GitHub
-
2026/02/17
Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
-
2026/02/17
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
2026/02/16
[jira] [Commented] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Mikael Carlstedt (Jira)
-
2026/02/16
Re: [PR] KAFKA-19048: Minimal movement replica balancing algorithm for reassignment [kafka]
via GitHub
-
2026/02/16
Re: [PR] jprnt02 [kafka]
via GitHub
-
2026/02/16
Re: [PR] MINOR: Note KS broker replication factor limitation [kafka]
via GitHub