jira
Thread
Date
Later messages
Messages by Date
2026/06/17
Re: [PR] KAFKA-20651: Cache parsed KafkaPrincipal in StandardAcl (#v1) [kafka]
via GitHub
2026/06/17
[jira] [Comment Edited] (KAFKA-20651) Cache parsed KafkaPrincipal in StandardAcl.kafkaPrincipal()
ibenchhida (Jira)
2026/06/17
[jira] [Commented] (KAFKA-20651) Cache parsed KafkaPrincipal in StandardAcl.kafkaPrincipal()
ibenchhida (Jira)
2026/06/17
[jira] [Assigned] (KAFKA-20583) KRaft controller does not support dynamic SSL certificate reload for CONTROLLER listener unlike broker listeners
Mahsa Seifikar (Jira)
2026/06/17
Re: [PR] KAFKA-20423: Fix flakiness of testWakeupWithFetchDataAvailable [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20610: Minor - Renaming variables to not include replica manager reference (5/N) [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Fix error message for streams group reset [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] HOTFIX: remove incorrect public API change [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
[PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka]
via GitHub
2026/06/17
[jira] [Commented] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable
Shekhar Prasad Rajak (Jira)
2026/06/17
[jira] [Updated] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable
Shekhar Prasad Rajak (Jira)
2026/06/17
Re: [PR] KAFKA-20116: Make task-offset-sum available to client background thread (1/N) [kafka]
via GitHub
2026/06/17
[jira] [Created] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable
Shekhar Prasad Rajak (Jira)
2026/06/17
[PR] KAFKA-20610: Minor - Renaming variables to not include replica manager reference (5/N) [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Rewrite FetchFromFollowerIntegrationTest from Scala to Java and move to server module [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Fix error message for streams group reset [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20678: Support share group DLQ remote record fetch. [kafka]
via GitHub
2026/06/17
[PR] KAFKA-20678: Support share group DLQ remote record fetch. [kafka]
via GitHub
2026/06/17
[PR] MINOR: Fix error message for streams group reset [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20610: Added abstraction classes for share fetch reads (1/N) [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Caching immutable voterKeys [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka]
via GitHub
2026/06/17
[PR] KAFKA-19583: fix: enable oauthbearer sasl with native image [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka]
via GitHub
2026/06/17
[jira] [Commented] (KAFKA-20049) kafka-site build depends on hvishwanath/hugo
ASF GitHub Bot (Jira)
2026/06/17
[jira] [Commented] (KAFKA-20541) Duplicate generated folder in kafka-site
ASF GitHub Bot (Jira)
2026/06/17
[PR] KAFKA-19543: fix(consumer): keep metrics available after close [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
Re: [PR] MINOR: Caching immutable voterKeys [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-15701: Expose the requesting principal to CreateTopicPolicy and AlterConfigPolicy [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
[PR] KAFKA-20491: Add uncommitted bytes limit [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-3073: Add topic regex support for Connect sinks [kafka]
via GitHub
2026/06/17
Re: [PR] KAFKA-3073: Add topic regex support for Connect sinks [kafka]
via GitHub
2026/06/16
[PR] HOTFIX: remove incorrect public API change [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (1/N) [kafka]
via GitHub
2026/06/16
[PR] KAFKA-20116: Make task-offset-sum available to client background thread (1/N) [kafka]
via GitHub
2026/06/16
[jira] [Updated] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers
kravii (Jira)
2026/06/16
[jira] [Created] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers
kravii (Jira)
2026/06/16
Re: [PR] KAFKA-20199: Use NodeId selector metric tag on controller-only KRaft nodes [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20237: Re-enqueue InitProducerId request after authentication failure [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19878 : Connect | Fixed order of arguments in assertEquals in connect package [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-18874: Fix KRaft controller registration retry on timeout [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19008 Remove scala version from artifacts [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19262 Add a test to verify all metrics naming pattern [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (1/N) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-17798: Add forbidden-apis linting to gradle build [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR: Add MockProducer and MockConsumer testing examples [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20032: KIP-1265 Automatic detection of internal API usage [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR: make processMessages task outputs relocatable for build cache [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
2026/06/16
Re: [PR] WIP: KAFKA-20292: Implement offloaded assignments [kafka]
via GitHub
2026/06/16
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
2026/06/16
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/16
[PR] KAFKA-15701: Expose the requesting principal to CreateTopicPolicy and AlterConfigPolicy [kafka]
via GitHub
2026/06/16
[PR] KAFKA-12759: Rebalance when a static member's subscription changes (classic protocol) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
2026/06/16
[jira] [Resolved] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted
Lianet Magrans (Jira)
2026/06/16
[jira] [Resolved] (KAFKA-20522) Refine test coverage for consumer close-on-interrupt best-effort behavior
Lianet Magrans (Jira)
2026/06/16
Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
[jira] [Created] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller
Haifeng Chen (Jira)
2026/06/16
Re: [PR] KAFKA-20377: Add to pass additional Docker build arguments in the system tests [kafka]
via GitHub
2026/06/16
[jira] [Updated] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer
Lianet Magrans (Jira)
2026/06/16
Re: [PR] KAFKA-20377: Add to pass additional Docker build arguments in the system tests [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20377: Add to pass additional Docker build arguments in the system tests [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20668: Add --checkpoint option to kafka-metadata-shell [kafka]
via GitHub
2026/06/16
[jira] [Resolved] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer
Jheng-Sing Chen (Jira)
2026/06/16
[PR] KAFKA-20693: Fix NPE in AbstractHerder config-validation error handling [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR; Refactor KRaft API around message handling [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR; Refactor KRaft API around message handling [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka]
via GitHub
2026/06/16
[PR] MINOR: Migrate AuthorizerIntegrationTest to ClusterInstance [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
[jira] [Updated] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders)
Matthias J. Sax (Jira)
2026/06/16
[jira] [Updated] (KAFKA-20701) KIP drafting, publication, discussion, vote
Matthias J. Sax (Jira)
2026/06/16
Re: [PR] KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context [kafka]
via GitHub
2026/06/16
[jira] [Assigned] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
Re: [PR] KAFKA-20377: Add to pass additional Docker build arguments in the system tests [kafka]
via GitHub
2026/06/16
[jira] [Assigned] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Assigned] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Assigned] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Assigned] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Assigned] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
[jira] [Created] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
2026/06/16
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
2026/06/16
[jira] [Created] (KAFKA-20701) KIP drafting, publication, discussion, vote
Jess Jin (Jira)
2026/06/16
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
2026/06/16
[jira] [Assigned] (KAFKA-20701) KIP drafting, publication, discussion, vote
Jess Jin (Jira)
2026/06/16
Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka]
via GitHub
2026/06/16
[jira] [Created] (KAFKA-20700) AllowedPaths should resolve symlinks before validating paths against allowed.paths
Nilesh Kumar (Jira)
2026/06/16
[PR] KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
[jira] [Created] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context
Jira
2026/06/16
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20270 [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20270 [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20088: CIDR-based Host Patterns for ACLs [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka]
via GitHub
2026/06/16
[PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20694: Fix share read leader epoch sentinel [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] MINOR: Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer [kafka]
via GitHub
2026/06/16
[jira] [Updated] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing
Andrew Schofield (Jira)
2026/06/16
[jira] [Resolved] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing
Andrew Schofield (Jira)
2026/06/16
Re: [PR] KAFKA-20694: Fix share read leader epoch sentinel [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (1/N) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka]
via GitHub
2026/06/16
[PR] KAFKA-20693: fix npe in abstract herder when no config value [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20673: Skip stale-leader lookup retry while the AdminClient is closing (follow-up) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
2026/06/16
Re: [PR] KSTREAMS-8781: Add back `rack.aware.assignment.tags` config [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Server Side. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Server Side. [kafka]
via GitHub
2026/06/16
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
2026/06/16
[jira] [Updated] (KAFKA-20693) NPE in error handling in AbstractHerder
Gaetan Collaud (Jira)
2026/06/15
Re: [PR] Mm2 fault tolerance enhancement [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20270 [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20668: Add --checkpoint option to kafka-metadata-shell [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20088: CIDR-based Host Patterns for ACLs [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20658: Fix Cast ByteBuffer BYTES to string encoding [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20676: do not fail startup when a non-supported user configured cipher is used [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20659: Reject unsupported MirrorMaker record versions at runtime [kafka]
via GitHub
2026/06/15
Re: [PR] MINOR: Move transaction coordinator leaf classes from Scala to Java [kafka]
via GitHub
2026/06/15
Re: [PR] MINOR: Split KafkaAdminClientTest into per-domain test classes [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20668: Add --checkpoint option to kafka-metadata-shell [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka]
via GitHub
2026/06/15
[jira] [Assigned] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic
Ming-Yen Chung (Jira)
2026/06/15
[jira] [Created] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor
Evan Zhou (Jira)
2026/06/15
Re: [PR] KSTREAMS-8781: Add back `rack.aware.assignment.tags` config [kafka]
via GitHub
2026/06/15
Re: [PR] Gradle 10 migration/20260615 2121 g951 to papi 20260609 [kafka]
via GitHub
2026/06/15
Re: [PR] Gradle 10 migration/20260615 2121 g951 to papi 20260609 [kafka]
via GitHub
2026/06/15
[PR] Gradle 10 migration/20260615 2121 g951 to papi 20260609 [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20116: WIP [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20116: WIP [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
2026/06/15
Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
Later messages