jira  

Messages by Date

• 2026/06/28 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/28 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20292 [3/N]: Lift member updates out of consumer and share TargetAssignmentBuilder [kafka] via GitHub
• 2026/06/27 Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka] via GitHub
• 2026/06/27 Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka] via GitHub
• 2026/06/27 Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka] via GitHub
• 2026/06/27 [PR] ci: pin GitHub Actions to full commit SHAs [kafka] via GitHub
• 2026/06/27 [PR] ci: pin GitHub Actions to full commit SHAs [kafka] via GitHub
• 2026/06/27 [jira] [Assigned] (KAFKA-12227) Add method "Producer#send" to return CompletionStage instead of Future Ming-Yen Chung (Jira)
• 2026/06/27 Re: [PR] MINOR: Fix missing parenthesis in under-min-ISR trace log [kafka] via GitHub
• 2026/06/27 [PR] KAFKA-20292 [4/N]: Lift member updates out of streams TargetAssignmentBuilder [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka] via GitHub
• 2026/06/27 [PR] KAFKA-20720: Lower level for client log on self-healing share session… [kafka] via GitHub
• 2026/06/27 Re: [PR] docs: update 'Testing a Streams Application' example code [kafka] via GitHub
• 2026/06/27 [PR] docs: update 'Testing a Streams Application' example code [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20223: Extended I/O Metrics Collection [kafka] via GitHub
• 2026/06/27 Re: [PR] KAFKA-20223: Extended I/O Metrics Collection [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20724: prevent duplicate task in tasks() during pause and resume [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20724: prevent duplicate task in tasks() during pause and resume [kafka] via GitHub
• 2026/06/26 Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
• 2026/06/26 [jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread Lucas Brutschy (Jira)
• 2026/06/26 Re: [PR] KAFKA-19408 : Add check for compression type mismatch for push telemetry requests [kafka] via GitHub
• 2026/06/26 Re: [PR] MM2: Add offset gap detection and basic topic reset handling in MirrorSourceTask [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: Test Producer's and Accumulator's Behavior When Batch Size is Zero [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19092: Fix flaky testBalancePartitionLeaders by reducing check interval and increasing timeout [kafka] via GitHub
• 2026/06/26 [jira] [Commented] (KAFKA-20735) Streams logs ERROR "Failed to acquire lock while closing the state store" for lock contention during back-to-back rebalances Lucas Brutschy (Jira)
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/26 [jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Matthias J. Sax (Jira)
• 2026/06/26 [jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Matthias J. Sax (Jira)
• 2026/06/26 [jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Matthias J. Sax (Jira)
• 2026/06/26 [jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Matthias J. Sax (Jira)
• 2026/06/26 Re: [PR] KAFKA-20665: Add refiner scaffolding for "streams" warmup tasks [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20665: Add refiner scaffolding for "streams" warmup tasks [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 [jira] [Commented] (KAFKA-20116) Support HA assignor in the streams rebalance protocol Matthias J. Sax (Jira)
• 2026/06/26 Re: [PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20490: Track committed and uncommitted RocksDB Positions [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 [jira] [Created] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Ziyun Fu (Jira)
• 2026/06/26 [jira] [Assigned] (KAFKA-20744) Add back `rack.aware.assignment.tags` config Ziyun Fu (Jira)
• 2026/06/26 Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-20297: Deprecate Time-accepting constructors in KafkaStreams and Metrics [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: Add 4.3.1 to system tests [kafka] via GitHub
• 2026/06/26 [PR] Added support for dynamic SSL certificate reload for controllers [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20686: Expand integration test suite for share group DLQ. [2/N] [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 [jira] [Resolved] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator. Apoorv Mittal (Jira)
• 2026/06/26 Re: [PR] KAFKA-20743: Restrict sentinel leader and state epoch in share coord. [kafka] via GitHub
• 2026/06/26 [PR] MINOR: Add 4.3.1 to system tests [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] via GitHub
• 2026/06/26 [jira] [Updated] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true Bill Bejeck (Jira)
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18707: Move KRaftMetadataCachePublisher to metadata module [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-18707: Move KRaftMetadataCachePublisher to metadata module [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-13152: Add input.buffer.max.bytes based on KIP-770 [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20741: Add ReadOnlyRecord IQv2 result type (KIP-1356) [kafka] via GitHub
• 2026/06/26 [jira] [Resolved] (KAFKA-20701) KIP drafting, publication, discussion, vote Jess Jin (Jira)
• 2026/06/26 [jira] [Resolved] (KAFKA-20727) Update Kafka Streams system tests for transactional stores Bill Bejeck (Jira)
• 2026/06/26 [jira] [Updated] (KAFKA-20727) Update Kafka Streams system tests for transactional stores Bill Bejeck (Jira)
• 2026/06/26 Re: [PR] MINOR: Fix ShareGroupCommandTest reset-offsets tests passing invalid --from-file scope combination [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20727: Update system tests for transactional state stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20741: Add ReadOnlyRecord IQv2 result type (KIP-1356) [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-14228 Support for nested structures: ValueToKey [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: reduce allocations constructing RecordHeaders [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: Code cleanups in coordinator-common runtime [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20665: Add refiner scaffolding for "streams" warmup tasks [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: Follow-up KAFKA-20696 [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-20743: Restrict sentinel leader and state epoch in share coord. [kafka] via GitHub
• 2026/06/26 [jira] [Created] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator. Sushant Mahajan (Jira)
• 2026/06/26 [jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics RITIK KUMAR JAISWAL (Jira)
• 2026/06/26 Re: [PR] KAFKA-19491 CONSUMER protocol metrics documentation [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-19491 CONSUMER protocol metrics documentation [kafka] via GitHub
• 2026/06/26 [jira] [Created] (KAFKA-20742) Start offset for newly initialized share partitions should be 0 Sushant Mahajan (Jira)
• 2026/06/26 Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka] via GitHub
• 2026/06/26 Re: [PR] MINOR: Follow-up KAFKA-20696 [kafka] via GitHub
• 2026/06/26 [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 Lucas Brutschy (Jira)
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20499: Add isolation-level reads to in-memory stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20490: Track committed and uncommitted RocksDB Positions [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-20490: Track committed and uncommitted RocksDB Positions [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka] via GitHub
• 2026/06/26 [PR] KAFKA-20499: Add isolation-level reads to in-memory stores [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka] via GitHub
• 2026/06/26 Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka] via GitHub
• 2026/06/26 [jira] [Updated] (KAFKA-20662) Proper error code for malformed request during online migration David Jacot (Jira)
• 2026/06/26 Re: [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] MINOR: Code cleanups in coordinator-common runtime [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 [jira] [Assigned] (KAFKA-20734) Offline partition can cause loss of transaction markers Wang Xiaoqing (Jira)
• 2026/06/25 [PR] KAFKA-20734: Return noNode for known partitions without endpoints [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka] via GitHub
• 2026/06/25 Re: [PR] MINOR: Rewrite SaslClientsWithInvalidCredentialsTest and rename to ConsumerGroupCommandSaslAuthenticationTest [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19200: Recover pre-allocated never-written time index on startup [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19867: fix(raft): avoid UpdateVoteRequest from broker-only nodes [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19880: fix(storage): reject non-zero sequence on first batch with no producer state [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20116: Send task-(end)-offset only if changed (4/N) [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] via GitHub
• 2026/06/25 [PR] MINOR: Fix ShareGroupCommandTest reset-offsets tests passing invalid --from-file scope combination [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20727: Update system tests for transactional state stores [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka] via GitHub
• 2026/06/25 [jira] [Comment Edited] (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/06/25 [jira] [Resolved] (KAFKA-20495) Transactional support for InMemorySessionStore and InMemoryWindowStore Bill Bejeck (Jira)
• 2026/06/25 Re: [PR] KAFKA-20495: Add transactional support to in-memory window and session stores [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20495: Add transactional support to in-memory window and session stores [kafka] via GitHub
• 2026/06/25 [jira] [Comment Edited] (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/06/25 Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20703: IQv2 TimestampedKeyWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-18998: Clean up AuthHelper following review feedback [kafka] via GitHub
• 2026/06/25 [PR] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20553: Remove Scala dependency from streams:integration-tests [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20116: Send task-(end)-offset only if changed (5/N) [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-14228 Support for nested structures: ValueToKey [kafka] via GitHub
• 2026/06/25 [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/06/25 [jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread Nikita Shupletsov (Jira)
• 2026/06/25 Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context [kafka] via GitHub
• 2026/06/25 Re: [PR] MINOR: reduce allocations constructing RecordHeaders [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] via GitHub
• 2026/06/25 [jira] [Resolved] (KAFKA-20498) RocksDBStore readOnly implementation Bill Bejeck (Jira)
• 2026/06/25 Re: [PR] KAFKA-20498: Add isolation-level reads to RocksDBStore [kafka] via GitHub
• 2026/06/25 Re: [PR] KAFKA-20498: Add isolation-level reads to RocksDBStore [kafka] via GitHub
• 2026/06/25 [jira] [Updated] (KAFKA-20740) It is possible to have more than one concurrent voter change operation Jira

• Earlier messages
• Later messages