Messages by Date
-
2026/07/03
Re: [PR] KAFKA-20760: Parameterise PositionRestartIntegrationTest over transactional mode [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20761: Add client logs for consumer group configs defined on the broker [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20761: Add client logs for consumer group configs defined on the broker [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20761: Add client logs for consumer group configs defined on the broker [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20768: Add transactional and IQ isolation to RocksDB window and session stores [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-20768: Add transactional and IQ isolation to RocksDB window and session stores [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-19663: kafka-broker-api tool should support to get controller api version [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20579: Initial producer incremental allocation for uncompressed data [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20598: Prevent polling unassigned consumer during ConsumerTask shutdown [kafka]
via GitHub
-
2026/07/03
[jira] [Assigned] (KAFKA-20757) Run store-level unit suites through the transactional path
Alan Lau (Jira)
-
2026/07/03
Re: [PR] KAFKA-19663: kafka-broker-api tool should support to get controller api version [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-18448: SSL support for ClusterTestExtensions [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-20678: Exception handling for read call in ReplicaManagerLogReader.readAsync. [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Document connections.max.idle.ms dependency on max.poll.interval.ms for Classic consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client) [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/03
[jira] [Created] (KAFKA-20768) RocksDB SegmentedStore readOnly implementation
Nicholas Telford (Jira)
-
2026/07/03
Re: [PR] KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client) [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20665: Bump group epoch for warm-up refinement steps [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client) [kafka]
via GitHub
-
2026/07/03
[jira] [Commented] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2]
Krishna Chidrawar (Jira)
-
2026/07/03
[jira] [Resolved] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2]
Chia-Ping Tsai (Jira)
-
2026/07/03
[jira] [Commented] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2]
Chia-Ping Tsai (Jira)
-
2026/07/03
Re: [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka]
via GitHub
-
2026/07/03
[jira] [Created] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2]
Krishna Chidrawar (Jira)
-
2026/07/03
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka]
via GitHub
-
2026/07/03
[PR] MINOR: Document connections.max.idle.ms dependency on max.poll.interval.ms for Classic consumer [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20665: Bump group epoch for warm-up refinement steps [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-20762 Add --zk-rollback-compatible flag to kafka-storage.sh format [kafka]
via GitHub
-
2026/07/03
[jira] [Commented] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0
Alex (Jira)
-
2026/07/03
[jira] [Commented] (KAFKA-20665) Add warmup task support to reconciler
Alieh Saeedi (Jira)
-
2026/07/03
[jira] [Commented] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0
Roland Sommer (Jira)
-
2026/07/03
Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20760: Parameterise PositionRestartIntegrationTest over transactional mode [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-20760: Parameterise PositionRestartIntegrationTest over transactional mode [kafka]
via GitHub
-
2026/07/03
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/07/03
Re: [PR] MINOR: Add MockProducer and MockConsumer testing examples [kafka]
via GitHub
-
2026/07/03
[PR] KAFKA-20761: Add client logs for consumer group configs defined on the broker [kafka]
via GitHub
-
2026/07/02
Re: [PR] MINOR: handle invalid StreamsHeartbeatRequest [kafka]
via GitHub
-
2026/07/02
[PR] KAFKA-20665: Bump group epoch for warm-up refinement steps [kafka]
via GitHub
-
2026/07/02
[jira] [Created] (KAFKA-20766) SASL channel authentication may block under slow/broken reverse DNS resolution during connection establishment
dongfang (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates
Nikita Shupletsov (Jira)
-
2026/07/02
[jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread
Nikita Shupletsov (Jira)
-
2026/07/02
[jira] [Created] (KAFKA-20765) AsyncKafkaConsumer: OffsetFetch retry on STALE_MEMBER_EPOCH can spin in dedup loop and never complete the application future
Alieh Saeedi (Jira)
-
2026/07/02
[jira] [Assigned] (KAFKA-20765) AsyncKafkaConsumer: OffsetFetch retry on STALE_MEMBER_EPOCH can spin in dedup loop and never complete the application future
Alieh Saeedi (Jira)
-
2026/07/02
[jira] [Commented] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." after a state updater remove times out during cold start rebalancing
Nikita Shupletsov (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20687) Consider improving unused chunks reuse
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20687) Consider improving unused chunks reuse
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Assigned] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates
Nikita Shupletsov (Jira)
-
2026/07/02
[jira] [Created] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates
Nikita Shupletsov (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20687) Consider improving unused chunks reuse when no data written
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Created] (KAFKA-20763) Mark producer allocation config as public
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Comment Edited] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0
Alex (Jira)
-
2026/07/02
[jira] [Commented] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0
Alex (Jira)
-
2026/07/02
[jira] [Created] (KAFKA-20762) Node replacements are not supported during KRaft migration
Anton Agestam (Jira)
-
2026/07/02
[jira] [Assigned] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic
Ming-Yen Chung (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20761) Add client logs for consumer group configs defined on the broker
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Created] (KAFKA-20761) Add client logs for consumer group configs defined on the broker
Lianet Magrans (Jira)
-
2026/07/02
[jira] [Resolved] (KAFKA-20032) KIP-1265 : Mechanism for automatic detection of internal API usage
Ashwin Pankaj (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20032) KIP-1265 : Mechanism for automatic detection of internal API usage
Ashwin Pankaj (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20746) NPE in MetadataCache#toCluster
Luke Chen (Jira)
-
2026/07/02
[jira] [Updated] (KAFKA-20746) NPE in MetadataCache#toCluster
Luke Chen (Jira)
-
2026/07/02
[PR] KAFKA-13009: do not add global state stores to per-task subtopologies [kafka]
via GitHub
-
2026/07/02
Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka]
via GitHub
-
2026/07/01
[jira] [Assigned] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing
Ken Huang (Jira)
-
2026/07/01
Re: [PR] KAFKA-20703: IQv2 TimestampedKeyWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka]
via GitHub
-
2026/07/01
[PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka]
via GitHub
-
2026/07/01
Re: [PR] 修复docker jvm构建错误(Fix Docker JVM build errors) [kafka]
via GitHub
-
2026/07/01
Re: [PR] Enhanced mirror maker2 base 4.0.0 for fail-fast and reset handling [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
2026/07/01
[jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread
Wang Xiaoqing (Jira)
-
2026/07/01
[jira] [Updated] (KAFKA-20741) Add ReadOnlyRecord Interface
Jess Jin (Jira)
-
2026/07/01
[PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/07/01
[PR] MINOR: handle invalid StreamsHeartbeatRequest [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
[jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment()
Colt McNealy (Jira)
-
2026/07/01
[PR] KAFKA-20760: Fix for Position integration test and persiting Position object [kafka]
via GitHub
-
2026/07/01
[jira] [Resolved] (KAFKA-20742) Start offset for newly initialized share partitions should be 0
Apoorv Mittal (Jira)
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka]
via GitHub
-
2026/07/01
[jira] [Created] (KAFKA-20760) IQv2 range queries fail and committed Position is lost on restart for transactional state store
Bill Bejeck (Jira)
-
2026/07/01
Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20756: Parameterize for transactional state stores [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
-
2026/07/01
[jira] [Commented] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing
Chia-Ping Tsai (Jira)
-
2026/07/01
[jira] [Created] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing
Chia-Ping Tsai (Jira)
-
2026/07/01
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Matthias J. Sax (Jira)
-
2026/07/01
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
-
2026/07/01
[jira] [Comment Edited] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
-
2026/07/01
[PR] KFK-19871: Add Runtime to TTD Multipartition [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka]
via GitHub
-
2026/07/01
Re: [PR] KFK-19871: A, Add Builder and Runtime for Multipartition for TopologyTestDriver [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka]
via GitHub
-
2026/07/01
[jira] [Updated] (KAFKA-20757) Run store-level unit suites through the transactional path
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Updated] (KAFKA-20758) Add lifecycle and recovery coverage
Bill Bejeck (Jira)
-
2026/07/01
Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka]
via GitHub
-
2026/07/01
[jira] [Created] (KAFKA-20758) Add lifecycle and recovery coverage
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Created] (KAFKA-20756) Parameterize integration tests over transactional state stores
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Created] (KAFKA-20757) Run store-level unit suites through the transactional path
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Created] (KAFKA-20755) Extend transactional state store test coverage
Bill Bejeck (Jira)
-
2026/07/01
Re: [PR] KAFKA-20579: Initial producer incremental allocation for uncompressed data [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20655: Mark KIP-1331 RPCs stable before release [kafka]
via GitHub
-
2026/07/01
[PR] MINOR: Prevent overflow in CreateTopics partition validation [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/07/01
[jira] [Resolved] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name
Chia-Ping Tsai (Jira)
-
2026/07/01
Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Update the AK doc to include changes in KIP-1291 [kafka]
via GitHub
-
2026/07/01
[jira] [Resolved] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS
Bill Bejeck (Jira)
-
2026/07/01
[jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS
Bill Bejeck (Jira)
-
2026/07/01
Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-17840: Move QuotaFactory to server module [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
[jira] [Updated] (KAFKA-20754) Disallow static member instance id changes
Sean Quah (Jira)
-
2026/07/01
[jira] [Created] (KAFKA-20754) Disallow static member instance id changes
Sean Quah (Jira)
-
2026/07/01
Re: [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-10397: do not expose statistics-based RocksDB metrics when the user provides a Statistics object [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka]
via GitHub
-
2026/07/01
Re: [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-10025: guard RocksDBMetricsRecorder value provider reads against store close [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka]
via GitHub
-
2026/07/01
[PR] KAFKA-20753: Fix transactional status marker writes [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20088: CIDR-based Host Patterns for ACLs [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/07/01
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20693: fix npe in abstract herder when no config value [kafka]
via GitHub
-
2026/06/30
Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka]
via GitHub
-
2026/06/30
Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka]
via GitHub
-
2026/06/30
[PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka]
via GitHub
-
2026/06/30
[PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/30
[jira] [Updated] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation
majialong (Jira)
-
2026/06/30
Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka]
via GitHub
-
2026/06/30
Re: [PR] Support keystore with multiple alias entries [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/30
Re: [PR] WIP: Removing WindowedSerializer interface from public class implementations [kafka]
via GitHub
-
2026/06/30
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub