Messages by Date
-
2026/06/24
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-20686: Add base integ tests for share group DLQ. [1/N] [kafka]
via GitHub
-
2026/06/24
Re: [PR] Sync 2 recent commits to 4.3 [kafka]
via GitHub
-
2026/06/24
Re: [PR] Sync 2 recent commits to 4.2 [kafka]
via GitHub
-
2026/06/24
[jira] [Resolved] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator
David Jacot (Jira)
-
2026/06/24
[jira] [Updated] (KAFKA-20662) Proper error code for malformed request during online migration
David Jacot (Jira)
-
2026/06/24
[jira] [Commented] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1)
Adam Horky (Jira)
-
2026/06/24
[PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
-
2026/06/24
[PR] MINOR: Code cleanups in coordinator-common runtime [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka]
via GitHub
-
2026/06/24
Re: [PR] KAFKA-19354 on 3.9 [kafka]
via GitHub
-
2026/06/24
[PR] KAFKA-19354 on 3.9 [kafka]
via GitHub
-
2026/06/24
[jira] [Commented] (KAFKA-20730) Remove spotless from streams-scala
Jiayao Sun (Jira)
-
2026/06/24
[PR] KAFKA-60665: Add refiner scaffolding for "streams" warmup tasks [kafka]
via GitHub
-
2026/06/24
[jira] [Updated] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1)
Adam Horky (Jira)
-
2026/06/24
Re: [PR] KAFKA-20116: Forwad task-(end)-offset to task assignor (4/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-19200: Recover pre-allocated never-written time index on startup [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20349: Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 [kafka]
via GitHub
-
2026/06/23
Re: [PR] DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" [kafka]
via GitHub
-
2026/06/23
Re: [PR] DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-15701: Expose the requesting principal to CreateTopicPolicy and AlterConfigPolicy [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20693: fix npe in abstract herder when no config value [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-12759: Rebalance when a static member's subscription changes (classic protocol) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20532: Defensive trimming of min.insync.replicas in controller and kafka-topics to tolerate whitespace-contaminated configs [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20693: Fix NPE in AbstractHerder config-validation error handling [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Move DelayedProduceTest to server module [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-20734) Offline partition can cause loss of transaction markers
Artem Livshits (Jira)
-
2026/06/23
[jira] [Updated] (KAFKA-20734) Offline partition can cause loss of transaction markers
Alyssa Huang (Jira)
-
2026/06/23
[jira] [Updated] (KAFKA-20734) Offline partition can cause loss of transaction markers
Alyssa Huang (Jira)
-
2026/06/23
[jira] [Created] (KAFKA-20734) Offline partition can cause loss of transaction markers
Alyssa Huang (Jira)
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
[PR] MINOR: Update docker_scan supported_image_tag for 4.3.1 [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20733: Fix fetchResponseWithUnexpectedPartitionIsIgnored passing for wrong reason with CONSUMER protocol [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20727: Update system tests for transactional state stores [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20733: Fix fetchResponseWithUnexpectedPartitionIsIgnored passing for wrong reason with CONSUMER protocol [kafka]
via GitHub
-
2026/06/23
[PR] Sync 2 recent commits to 4.3 [kafka]
via GitHub
-
2026/06/23
[PR] Sync 2 recent commits to 4.2 [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
[PR] KAFKA-20579: Initial producer incremental allocation for uncompressed data [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20498: Add isolation-level reads to RocksDBStore [kafka]
via GitHub
-
2026/06/23
[PR] KAFKA-20498: Add isolation-level reads to RocksDBStore [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20495: Add transactional support to in-memory window and session stores [kafka]
via GitHub
-
2026/06/23
Re: [PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs
Justine Olshan (Jira)
-
2026/06/23
[PR] KAFKA-20495: Add transactional support to in-memory window and session stores [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Migrate AuthorizerIntegrationTest to ClusterInstance [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka]
via GitHub
-
2026/06/23
[jira] [Updated] (KAFKA-17164) Consider to enforce application.server <server>:<port> format at config level
Matthias J. Sax (Jira)
-
2026/06/23
[jira] [Resolved] (KAFKA-17164) Consider to enforce application.server <server>:<port> format at config level
Matthias J. Sax (Jira)
-
2026/06/23
Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka]
via GitHub
-
2026/06/23
[jira] [Updated] (KAFKA-20730) Remove spotless from streams-scala
Matthias J. Sax (Jira)
-
2026/06/23
[jira] [Commented] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol
Lianet Magrans (Jira)
-
2026/06/23
[PR] KAFKA-20733: Fix fetchResponseWithUnexpectedPartitionIsIgnored passing for wrong reason with CONSUMER protocol [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20259: Verify IQv1 and IQv2 do not break with headers-aware state stores [kafka]
via GitHub
-
2026/06/23
[PR] MINOR: Merge kafka.security classes into test-common [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka]
via GitHub
-
2026/06/23
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
-
2026/06/23
Re: [PR] KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Migrate AuthorizerIntegrationTest to ClusterInstance [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
[jira] [Created] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol
Jiwon Park (Jira)
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-19193: trace-log rack-specific load stats in rack-aware mode [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20686: Add base integ tests for share group DLQ. [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-19871 - Add partition support to TestRecord [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20223: Extended I/O Metrics Collection [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-17840: Move ClientRequestQuotaManager to server module [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20645: Move LogLoaderTest to storage module [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread
Eswarar Siva (Jira)
-
2026/06/23
Re: [PR] KAFKA-19871 - Add partition support to TestRecord [kafka]
via GitHub
-
2026/06/23
Re: [PR] (WIP-PoC) KIP-1356: IQv2 TimestampedKeyWithHeadersQuery for headers-aware state stores [kafka]
via GitHub
-
2026/06/23
[jira] [Resolved] (KAFKA-20524) Initialization of share group offsets from a specific offset or a file
Andrew Schofield (Jira)
-
2026/06/23
Re: [PR] KAFKA-20524: Improve reset offset usability [kafka]
via GitHub
-
2026/06/23
[jira] [Assigned] (KAFKA-20724) Topology pausing may have race condition
Eswarar Siva (Jira)
-
2026/06/23
[PR] KAFKA-20724: prevent duplicate task in tasks() during pause and resume [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20116: Send task-(end)-offset only if changed (5/N) [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20223: Extended I/O Metrics Collection [kafka]
via GitHub
-
2026/06/23
[jira] [Updated] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1)
Adam Horky (Jira)
-
2026/06/23
Re: [PR] KAFKA-13716: Add unit tests for DeleteRecordsCommand [kafka]
via GitHub
-
2026/06/23
[jira] [Created] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1)
Adam Horky (Jira)
-
2026/06/23
Re: [PR] MINOR: Move DelayedProduceTest to server module [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Move DelayedProduceTest to server module [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Remove jqwik dependency [kafka]
via GitHub
-
2026/06/23
Re: [PR] MINOR: Remove jqwik dependency [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20490: Replace txn buffer skip-list with TreeMap [kafka]
via GitHub
-
2026/06/23
[PR] KAFKA-20490: Replace txn buffer skip-list with TreeMap [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-20608) classic consumer static member rejoin can fail with GroupMaxSizeReachedException at max size
Nilesh Kumar (Jira)
-
2026/06/23
Re: [PR] KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) [kafka]
via GitHub
-
2026/06/23
[jira] [Updated] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread
Eswarar Siva (Jira)
-
2026/06/23
Re: [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-20724) Topology pausing may have race condition
Eswarar Siva (Jira)
-
2026/06/23
[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
Eswarar Siva (Jira)
-
2026/06/23
[jira] [Created] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread
Eswarar Siva (Jira)
-
2026/06/23
[jira] [Resolved] (KAFKA-20729) RocksDBTransactionBuffer missing newBaseSnapshotIterator breaks trunk compile
Nilesh Kumar (Jira)
-
2026/06/23
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups [kafka]
via GitHub
-
2026/06/23
[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
Eswarar Siva (Jira)
-
2026/06/23
Re: [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20723: Add fail fast check for share group dlq(...). [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
2026/06/23
[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/23
[PR] KAFKA-20686: Add base integ tests for share group DLQ. [1/N] [kafka]
via GitHub
-
2026/06/23
[jira] [Commented] (KAFKA-20724) Topology pausing may have race condition
Lucas Brutschy (Jira)
-
2026/06/23
[jira] [Updated] (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/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] HOTFIX: fix compilation error [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka]
via GitHub
-
2026/06/23
[jira] [Resolved] (KAFKA-20601) ConsumerGroup static member rejoin can fail with GroupMaxSizeReachedException at max size
David Jacot (Jira)
-
2026/06/23
Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka]
via GitHub
-
2026/06/23
Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka]
via GitHub
-
2026/06/23
[jira] [Resolved] (KAFKA-20662) Proper error code for malformed request during online migration
David Jacot (Jira)
-
2026/06/23
Re: [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-19871 - Add partition support to TestRecord [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-19871 - Add partition support to TestRecord [kafka]
via GitHub
-
2026/06/22
Re: [PR] MINOR: reduce allocations constructing RecordHeaders [kafka]
via GitHub
-
2026/06/22
Re: [PR] MINOR: move DelayedProduceTest to server module [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
[PR] HOTFIX: fix compilation error [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka]
via GitHub
-
2026/06/22
[PR] KAFKA-20116: Send task-(end)-offset only if changed (5/N) [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20253: Fix high CPU spin loop after failed SASL re-authentication [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-19735: Add automatic commit offset caching in subscribe mode [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-18608: feat: implement private_key_jwt client authentication for OAuth 2.0 [kafka]
via GitHub
-
2026/06/22
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
-
2026/06/22
[PR] KAFKA-20116: Forwad task-(end)-offset-sum to task assignor (4/N) [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA: Clarify allow.everyone.if.no.acl.found documentation [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-8035: Add lambda and anonymous class tests for KStream API generics [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20692: Add unit tests for ToolsUtils [kafka]
via GitHub
-
2026/06/22
Re: [PR] MINOR: Migrate SaslClientsWithInvalidCredentialsTest to ClusterInstance [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-19200: Recover pre-allocated never-written time index on startup [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
[jira] [Assigned] (KAFKA-20730) Remove spotless from streams-scala
Jiayao Sun (Jira)
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
[jira] [Commented] (KAFKA-20730) Remove spotless from streams-scala
Chia-Ping Tsai (Jira)
-
2026/06/22
[jira] [Created] (KAFKA-20730) Remove spotless from streams-scala
Chia-Ping Tsai (Jira)
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
Re: [PR] MINOR: Move transaction coordinator leaf classes from Scala to Java [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka]
via GitHub
-
2026/06/22
Re: [PR] KAFKA-14922: Fail fast if application.id does not exist as consumer group in StreamsResetter [kafka]
via GitHub