jira
Thread
Date
Earlier messages
Messages by Date
2026/02/11
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/11
[jira] [Commented] (KAFKA-20090) TV2 can allow for ongoing transactions with max epoch that never complete
sanghyeok An (Jira)
2026/02/11
[jira] [Commented] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Jira
2026/02/11
Re: [PR] KAFKA-20110 Fix generated doc and Javadoc for dynamic configs [kafka]
via GitHub
2026/02/11
[PR] MINOR: Various small cleanups in group-coordinator [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20110 Fix generated doc and Javadoc for dynamic configs [kafka]
via GitHub
2026/02/11
[jira] [Assigned] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Ming-Yen Chung (Jira)
2026/02/11
Re: [PR] KAFKA-20110 Fix generated doc and Javadoc for dynamic configs [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20127: Add new methods to StateSerdes [kafka]
via GitHub
2026/02/11
[jira] [Resolved] (KAFKA-19874) Fix resource leak in TopicBasedRemoteLogMetadataManager initialization
Kamal Chandraprakash (Jira)
2026/02/11
[jira] [Commented] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Chia-Ping Tsai (Jira)
2026/02/11
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/11
[jira] [Commented] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Lucas Brutschy (Jira)
2026/02/11
[jira] [Updated] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Lucas Brutschy (Jira)
2026/02/11
[jira] [Created] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Chia-Ping Tsai (Jira)
2026/02/11
[jira] [Resolved] (KAFKA-19361) document that `mapKey` does not break the compatibility
Chia-Ping Tsai (Jira)
2026/02/11
Re: [PR] KAFKA-19361: Document that `mapKey` does not break the serialization compatibility [kafka]
via GitHub
2026/02/11
[jira] [Commented] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Chia-Ping Tsai (Jira)
2026/02/11
[jira] [Updated] (KAFKA-17125) Streams Rebalance Protocol - Core Feature Set
Lucas Brutschy (Jira)
2026/02/11
Re: [PR] MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol [kafka]
via GitHub
2026/02/11
Re: [PR] MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol [kafka]
via GitHub
2026/02/11
[jira] [Created] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams
Lucas Brutschy (Jira)
2026/02/11
[jira] [Commented] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller
Jira
2026/02/11
Re: [PR] MINOR: use correct deserialize method in ValueTimestampHeaders [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (1/N) [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (1/N) [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20122: Create HeadersBytesStore [kafka]
via GitHub
2026/02/11
Re: [PR] KAFKA-20122: Create HeadersBytesStore [kafka]
via GitHub
2026/02/11
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/11
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/10
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/10
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/10
Re: [PR] [WIP] Draft proposal for adding retries to timed out KS EOS commit requests [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
2026/02/10
Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka]
via GitHub
2026/02/10
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Fix JDK version and architecture parameters in system test worker provisioning [kafka]
via GitHub
2026/02/10
[jira] [Assigned] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Eric Chang (Jira)
2026/02/10
[jira] [Commented] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Eric Chang (Jira)
2026/02/10
[jira] [Commented] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit
Chia-Ping Tsai (Jira)
2026/02/10
[jira] [Created] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Chia-Ping Tsai (Jira)
2026/02/10
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Replace FutureUtils.failedFuture with CompletableFuture.failedFuture [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka]
via GitHub
2026/02/10
[PR] MINOR: use correct deserialize method in ValueTimestampHeaders [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka]
via GitHub
2026/02/10
[PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20122: Create HeadersBytesStore [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20122: Create HeadersBytesStore [kafka]
via GitHub
2026/02/10
[jira] [Resolved] (KAFKA-19833) Reduce code duplication in nullable protocol types
Jun Rao (Jira)
2026/02/10
Re: [PR] KAFKA-19833: Reduce code duplication in nullable protocol types [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Add character range support to Glob patterns in Kafka shell [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-17411: Add new StateStore interfaces [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20130: Move RecordValidationStats to storage module [kafka]
via GitHub
2026/02/10
[jira] [Updated] (KAFKA-20132) Implement TimestampedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
2026/02/10
[jira] [Updated] (KAFKA-20134) Implement TimestampedWindowStoreWithHeaders
Matthias J. Sax (Jira)
2026/02/10
[jira] [Updated] (KAFKA-20155) Implement lazy deserialization mechanism
Matthias J. Sax (Jira)
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Fix JDK version and architecture parameters in system test worker provisioning [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Fix JDK version and architecture parameters in system test worker provisioning [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (1/N) [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Decouple timer and executor from CoordinatorRuntime [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR: Add java version check command to README [kafka]
via GitHub
2026/02/10
[jira] [Created] (KAFKA-20165) Consumer poll may fail with unrecoverable KafkaException if topic not in metadata when fetching committed offsets
Lianet Magrans (Jira)
2026/02/10
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/10
[PR] MINOR: Replace FutureUtils.failedFuture with CompletableFuture.failedFuture [kafka]
via GitHub
2026/02/10
[PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
2026/02/10
[jira] [Created] (KAFKA-20164) Add Kraft layer support for snapshots with metadata records via new handeLoadBootstrap
John Mannooparambil (Jira)
2026/02/10
[jira] [Assigned] (KAFKA-20153) Upgrade ducktape from 0.12 to 0.13
Nick Guo (Jira)
2026/02/10
[jira] [Assigned] (KAFKA-20152) Remove unused CoordinatorMetrics#registry
Nick Guo (Jira)
2026/02/10
Re: [PR] KAFKA-19434: Startup state stores initialization [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
2026/02/10
[PR] KAFKA-20137: Add javadoc to public APIs in org.apache.kafka.clients.producer [kafka]
via GitHub
2026/02/10
[PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders(1/N) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19951: Update lz4 dependency version for CVE-2025-12183 & CVE-2025-66566 [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
2026/02/10
Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka]
via GitHub
2026/02/10
[PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
2026/02/10
[jira] [Updated] (KAFKA-20163) Missing MM2 default exclude configs
Federico Valeri (Jira)
2026/02/10
[jira] [Comment Edited] (KAFKA-19992) Allow to configure max memory for restore path
Jira
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
[jira] [Updated] (KAFKA-20110) KAFKA-20110 Fix generated doc and Javadoc for dynamic configs
Maros Orsak (Jira)
2026/02/10
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/10
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/10
[PR] Implement content checksum verification in Lz4BlockInputS… [kafka]
via GitHub
2026/02/10
[jira] [Updated] (KAFKA-20113) Add Configurable Retry Parameters for Status Backing Store
Christo Lolov (Jira)
2026/02/10
[jira] [Updated] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
2026/02/10
[jira] [Created] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
2026/02/10
[jira] [Updated] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
2026/02/10
[PR] KAFKA-19361: Document that `mapKey` does not break the serialization compatibility [kafka]
via GitHub
2026/02/10
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20162) Validation and enforcement of group configurations
Andrew Schofield (Jira)
2026/02/09
[jira] [Assigned] (KAFKA-20162) Validation and enforcement of group configurations
Andrew Schofield (Jira)
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Andrew Schofield (Jira)
2026/02/09
[jira] [Assigned] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Andrew Schofield (Jira)
2026/02/09
[jira] [Commented] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Andrew Schofield (Jira)
2026/02/09
[jira] [Assigned] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Andrew Schofield (Jira)
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-20158) Implement SessionStoreWithHeaders
Matthias J. Sax (Jira)
2026/02/09
[jira] [Commented] (KAFKA-20096) RocksDB compatibility not documented
Matthias J. Sax (Jira)
2026/02/09
Re: [PR] EN-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
Kamal Chandraprakash (Jira)
2026/02/09
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/09
Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
2026/02/09
Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-17521: Avoid WARN on cleanup when state directory only contains process metadata. [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20099: Clarify how stream-time works in the docs [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20099: Clarify how stream-time works in the docs [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20099: Clarify how stream-time works in the docs [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20162) Validation and enforcement of group configurations
majialong (Jira)
2026/02/09
Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka]
via GitHub
2026/02/09
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/09
[PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Matthias J. Sax (Jira)
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Fix SSL certificate verification failure in system test worker provisioning [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Fix SSL certificate verification failure in system test worker provisioning [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-19831) Failures in the StateUpdater thread may lead to inability to shut down a stream thread
Matthias J. Sax (Jira)
2026/02/09
Re: [PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Matthias J. Sax (Jira)
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19687: MetaDataShell log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20092 buildscript and project dependencies version updates [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Add character range support to Glob patterns in Kafka shell [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19963: Add more information to doc to explain how to parallelize per topic with Kafka Streams [kafka]
via GitHub
2026/02/09
[PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-19833) Reduce code duplication in nullable protocol types
Lan Ding (Jira)
2026/02/09
[jira] [Updated] (KAFKA-19833) Reduce code duplication in nullable protocol types
Lan Ding (Jira)
2026/02/09
Re: [PR] KAFKA-19833: Refactor Nullable Types to Use a Unified Pattern [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Lan Ding (Jira)
2026/02/09
[jira] [Resolved] (KAFKA-19984) Throttle-related dynamic configurations should not have the `isReadOnly` flag
Chia-Ping Tsai (Jira)
2026/02/09
Re: [PR] KAFKA-19984 Throttle-related dynamic configurations should not have the `isReadOnly` flag [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20110 Fix DynamicQuotaConfig [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20110 Fix DynamicQuotaConfig [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Add test for ConfigDef.convertToString with null type [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20130: Move RecordValidationStats to storage module [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Ming-Yen Chung (Jira)
2026/02/09
Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit
Chia-Ping Tsai (Jira)
2026/02/09
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Genseric Ghiro (Jira)
2026/02/09
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Genseric Ghiro (Jira)
2026/02/09
Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit
Chia-Ping Tsai (Jira)
2026/02/09
[PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20128: Add missing TimestampType to java doc and move non-public classes to internal subpackage [kafka]
via GitHub
2026/02/09
[jira] [Commented] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
2026/02/09
[jira] [Assigned] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
2026/02/09
Re: [PR] [WIP / POC] KAFKA-20082: Hide record implementation from user [kafka]
via GitHub
2026/02/09
[jira] [Updated] (KAFKA-20142) Add javadoc to org.apache.kafka.streams module
Matthias J. Sax (Jira)
2026/02/09
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Matthias J. Sax (Jira)
2026/02/09
Re: [PR] KAFKA-20096: Add documentation about the incompatibility of RocksDB file format [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Ensure CoordinatorRuntime does not throw synchronous exceptions when returning futures [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: Decouple timer and executor from CoordinatorRuntime [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-20096: Add documentation about the incompatibility of RocksDB file format [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka]
via GitHub
2026/02/09
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
2026/02/09
[jira] [Resolved] (KAFKA-20129) Server error caused by appending/subtracting a non-existent config key
Chia-Ping Tsai (Jira)
Earlier messages