jira@kafka.apache.org, 2026-06

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PR] KAFKA-20423: Fix flakiness of testWakeupWithFetchDataAvailable [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 04:39:24 UTC, 5 replies.
- Re: [PR] MINOR: Move TransactionStateManager leaf case classes to Java records in transaction-coordinator [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 04:39:29 UTC, 3 replies.
- Re: [PR] MINOR: Add startup-duration logging to help with Kafka startup performance tuning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 04:40:31 UTC, 0 replies.
- Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 04:40:59 UTC, 0 replies.
- Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 04:41:10 UTC, 0 replies.
- Re: [PR] MINOR: Optimize Struct.validate() field iteration [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/01 05:11:45 UTC, 1 replies.
- Re: [PR] KAFKA-20645: Move LogLoaderTest to storage module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/01 05:18:36 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20647) Add example for Queues for Kafka - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/06/01 06:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20647) Add example for Queues for Kafka - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/06/01 06:18:00 UTC, 0 replies.
- [PR] MINOR: Use DLQ topic for share group id to enable DLQ. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/01 08:03:54 UTC, 7 replies.
- Re: [PR] KAFKA-19648; Cluster metadata bootstrapping with kraft checkpoint [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/06/01 08:43:30 UTC, 1 replies.
- Re: [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/06/01 08:46:31 UTC, 17 replies.
- Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/01 08:51:26 UTC, 18 replies.
- Re: [PR] MINOR: A starting point for a formal security model [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/01 08:54:48 UTC, 11 replies.
- Re: [PR] MINOR: Add toString() to KafkaMetric for readable logging [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/01 09:01:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/01 09:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19528) Release script does not handle doing multiple release candidates - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/01 09:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19404) Connect's plugin.path documentation does not match behavior - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/01 09:17:00 UTC, 1 replies.
- Re: [PR] MINOR: Split KafkaAdminClientTest into per-domain test classes [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/06/01 09:35:19 UTC, 2 replies.
- Re: [PR] KAFKA-20639: Move EnvelopeUtils to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/01 09:37:28 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20639) Move EnvelopeUtils to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/01 09:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/06/01 10:02:48 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19964) API Versions Response returns minimum metadata version for finalized level when no quorum exists - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/01 10:04:00 UTC, 0 replies.
- Re: [PR] Add draft threat model + SECURITY.md + AGENTS.md for security-model discoverability [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/06/01 11:32:46 UTC, 3 replies.
- Re: [PR] KAFKA-20394: Close stale broker connections when host or resolved IP changes [kafka] - posted by "gomudayya (via GitHub)" <gi...@apache.org> on 2026/06/01 12:02:21 UTC, 0 replies.
- [PR] Enhances MirrorMaker 2 with fault-tolerance for two critical data integrity scenarios. [kafka] - posted by "prudhvi9121 (via GitHub)" <gi...@apache.org> on 2026/06/01 12:46:16 UTC, 1 replies.
- [jira] [Created] (KAFKA-20648) Move Processor to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/01 12:49:00 UTC, 0 replies.
- Re: [PR] MINOR:Add 4.2.1 to docker_scan workflow [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/01 12:56:09 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/06/01 13:13:00 UTC, 0 replies.
- [PR] KAFKA-20610: Minor - correcting test and scala imports (4/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/01 13:20:46 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20649) KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL - posted by "Hannes Buseyne (Jira)" <ji...@apache.org> on 2026/06/01 13:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20649) KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL - posted by "Hannes Buseyne (Jira)" <ji...@apache.org> on 2026/06/01 13:26:00 UTC, 0 replies.
- [PR] KAFKA-20648: Move Processor object and tests to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/01 13:28:19 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14826) Log the completion time for request that resulted in an error. - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/01 13:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15269) Clean up the RaftClient interface - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/01 13:43:00 UTC, 0 replies.
- [PR] KAFKA-14276: Clarify java doc for ProcessorAPI init method and stateStore.approximateNumEntries() [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/06/01 13:53:16 UTC, 1 replies.
- [PR] KAFKA-20649: KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL [kafka] - posted by "buseynehannes (via GitHub)" <gi...@apache.org> on 2026/06/01 14:05:11 UTC, 1 replies.
- Re: [PR] KAFKA-20385 [1/N]: Add RebalanceConsumer interface and callback impl [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/06/01 14:17:17 UTC, 7 replies.
- Re: [PR] KAFKA-20072 Don't generate IDs with hyphens [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2026/06/01 14:31:34 UTC, 3 replies.
- [jira] [Created] (KAFKA-20650) In combined mode, BrokerServer and ControllerServer each independently called QuotaFactory.instantiate(), which created a separate ClientQuotaCallback instance via reflection for each role. - posted by "Patrick Allen (Jira)" <ji...@apache.org> on 2026/06/01 14:35:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix minor typos in CompletableEventReaperTest and LeaderEpochFileCache [kafka] - posted by "RonGamzu (via GitHub)" <gi...@apache.org> on 2026/06/01 14:44:57 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20352) Update version in trunk docs - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/01 15:09:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-19404) Connect's plugin.path documentation does not match behavior - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/01 15:10:00 UTC, 0 replies.
- [PR] KAFKA-20072 Make Uuid no-dash behavior opt-in [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2026/06/01 15:10:17 UTC, 3 replies.
- Re: [PR] KAFKA-14922: Fail fast if application.id does not exist as consumer group in StreamsResetter [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/01 15:22:19 UTC, 9 replies.
- [jira] [Commented] (KAFKA-13387) DescribeUserScramCredentialsResponse does not include entries from the request when there's an error - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/01 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20621) Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/01 16:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20651) StandardAuthorizerData.checkSection infinite loop when ACL resource name is a prefix of the queried resource - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/01 16:23:00 UTC, 0 replies.
- Re: [PR] KAFKA-20336: Add documentation DSL headers-aware state stores [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/01 16:34:12 UTC, 5 replies.
- [jira] [Created] (KAFKA-20652) Improve/Fix java docs - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/01 16:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20652) Improve/Fix java docs - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/01 16:50:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20652) Improve/Fix java docs - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/01 16:50:00 UTC, 3 replies.
- Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/01 17:11:14 UTC, 0 replies.
- Re: [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredWindowStore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/01 17:21:16 UTC, 4 replies.
- Re: [PR] KAFKA-20395: Support unregistering controllers [kafka] - posted by "josefk31 (via GitHub)" <gi...@apache.org> on 2026/06/01 17:28:51 UTC, 11 replies.
- [jira] [Updated] (KAFKA-20651) StandardAuthorizer: cache KafkaPrincipal in StandardAcl to eliminate allocation hotspot - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/01 17:39:00 UTC, 4 replies.
- Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/01 17:43:34 UTC, 0 replies.
- Re: [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredKeyValueStore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/01 17:49:17 UTC, 3 replies.
- [PR] KAFKA-20444: [10/N] Wire topic IDs through TransactionManager (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/01 18:43:58 UTC, 7 replies.
- [PR] KAFKA-20634: Spurious HighWatermarkUpdate failed errors in the group coordinator after partition leadership change [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/01 18:58:06 UTC, 8 replies.
- Re: [PR] KAFKA-20497: Add readOnly(IsolationLevel) to CachingKeyValueStore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/01 19:29:09 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20651) High CPU usage in StandardAuthorizerData.findAclRule due to O(N) ACL scanning and lack of principal-level indexing - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/01 19:33:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20651) Cache parsed KafkaPrincipal in StandardAcl.kafkaPrincipal() - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/01 20:19:00 UTC, 2 replies.
- Re: [PR] KAFKA-20497: Add readOnly(IsolationLevel) to CachingWindowStore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/01 21:46:50 UTC, 4 replies.
- [PR] KAFKA-17689: Remove unused TieredStorageTestHarness [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/06/02 01:44:15 UTC, 6 replies.
- Re: [PR] KAFKA-14615: Use sizeCompare for collection size equality checks [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 04:36:29 UTC, 0 replies.
- Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 04:36:52 UTC, 0 replies.
- Re: [PR] KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 05:04:34 UTC, 0 replies.
- Re: [PR] KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 05:04:37 UTC, 1 replies.
- Re: [PR] MINOR: Move KRaftMetadataCachePublisher to metadata module and convert to Java [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/02 05:04:44 UTC, 1 replies.
- [PR] MINOR: Remove redundant start calls from persister and dlq mgr. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/02 05:31:35 UTC, 1 replies.
- [PR] MINOR: fix doc for CVE-2026-41115 [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/06/02 08:05:25 UTC, 1 replies.
- [PR] MINOR: Add missing GROUP_ID_NOT_FOUND in {Consumer,Share,Streams}GroupHeartbeatResponse schema [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/02 08:11:07 UTC, 1 replies.
- [PR] Minor: Correcting reviewers script for names [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/02 09:35:57 UTC, 0 replies.
- [PR] MINOR: Don't enforce rebalance under the Streams group protocol [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/02 09:40:25 UTC, 1 replies.
- Re: [PR] KAFKA-20620: Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/02 09:43:45 UTC, 3 replies.
- Re: [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/02 09:55:53 UTC, 21 replies.
- [PR] Enhance MirrorMaker 2 with log truncation detection and topic reset recovery [kafka] - posted by "prudhvi9121 (via GitHub)" <gi...@apache.org> on 2026/06/02 11:50:05 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20352) Update version in trunk docs - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/02 12:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18209) Cleanup __transaction_state config logic - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/02 12:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18209) Cleanup __transaction_state config logic - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/02 12:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20594) Kafka Streams issue - posted by "Aayush Gupta (Jira)" <ji...@apache.org> on 2026/06/02 13:05:00 UTC, 1 replies.
- Re: [PR] KAFKA-20497: Add TimeOrderedCachingWindowStore#readOnly [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/02 13:29:11 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-20576) Dynamic memory allocation for the KafkaProducer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/02 13:57:00 UTC, 1 replies.
- [PR] KAFKA-14597: record-e2e-latency-max only considers consumption latencies but not processing delays [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/06/02 14:11:49 UTC, 2 replies.
- [PR] KAFKA-20532: Defensive trimming of min.insync.replicas in controller and kafka-topics to tolerate whitespace-contaminated configs [kafka] - posted by "sahildevgon (via GitHub)" <gi...@apache.org> on 2026/06/02 14:16:38 UTC, 3 replies.
- Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol (1/N) [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/02 14:17:24 UTC, 11 replies.
- [jira] [Assigned] (KAFKA-20507) Clarify consumer docs around commits without metadata & invalid position handling - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/02 14:29:00 UTC, 1 replies.
- [PR] KAFKA-20223: Extended I/O Metrics Collection [kafka] - posted by "sahildevgon (via GitHub)" <gi...@apache.org> on 2026/06/02 14:35:16 UTC, 18 replies.
- Re: [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredSessionStore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/02 14:50:32 UTC, 1 replies.
- [PR] KAFKA-20652: a couple of java-doc typo fixing [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/06/02 15:04:31 UTC, 1 replies.
- [PR] KAFKA-18209: Clean up transaction state topic config logic [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/02 15:06:24 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure - posted by "Evan Zhou (Jira)" <ji...@apache.org> on 2026/06/02 15:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13976) Improvements for OpenAPI specs - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/02 16:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-13976) Improvements for OpenAPI specs - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/02 16:31:00 UTC, 0 replies.
- [PR] KAFKA-20640: Consumer group accepts new classic members when migratio… [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/02 18:53:35 UTC, 0 replies.
- Re: [PR] MINOR: Switched RecordAccumulator.append from ByteBuffer to ByteBufferOutputStream. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/06/02 20:08:41 UTC, 1 replies.
- Re: [PR] KAFKA-20632: Added ChunkedBufferPool that can allocate multiple byte buffers at once. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/06/02 20:09:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20653) Remove deprecated headerless StateSerdes methods (keyFrom/valueFrom/rawKey/rawValue) - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/02 20:43:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20653) Remove deprecated headerless StateSerdes methods (keyFrom/valueFrom/rawKey/rawValue) - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/02 20:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20654) Remove deprecated boolean-isTimestamped methods and the constructors in Dsl{KeyValue,Window,Session}Params - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/02 20:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20654) Remove deprecated boolean-isTimestamped methods and the constructors in Dsl{KeyValue,Window,Session}Params - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/02 20:55:00 UTC, 3 replies.
- Re: [PR] KAFKA-10317: Global thread should honor shutdown signal during bootstrapping [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/06/02 21:00:52 UTC, 9 replies.
- [PR] KAFKA-13152: Add input.buffer.max.bytes (KIP-770) [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/06/02 21:10:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-20655) Mark KIP-1331 RPCs stable before release - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/02 22:32:00 UTC, 0 replies.
- Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/02 23:53:37 UTC, 7 replies.
- Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 04:36:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20009) Top level pages should include short descriptions for each section - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/03 05:09:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20009) Top level pages should include short descriptions for each section - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/03 05:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 05:11:07 UTC, 1 replies.
- Re: [PR] fix: replace 12 bare except clauses with except Exception [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/03 05:11:18 UTC, 1 replies.
- [PR] make the __remote_log_metadata topic compact [kafka] - posted by "TinaTong-coder (via GitHub)" <gi...@apache.org> on 2026/06/03 06:36:50 UTC, 1 replies.
- [PR] KAFKA-20444: [11/N] Refresh metadata before TxnOffsetCommit (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/03 08:11:31 UTC, 9 replies.
- [jira] [Created] (KAFKA-20656) Struct BYTES handling does not normalize ByteBuffer values - posted by "Ruiqi Dong (Jira)" <ji...@apache.org> on 2026/06/03 08:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20657) JsonConverter serializes ByteBuffer BYTES values using the backing array - posted by "Ruiqi Dong (Jira)" <ji...@apache.org> on 2026/06/03 08:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20658) Cast SMT encodes ByteBuffer BYTES from index 0 instead of remaining bytes - posted by "Ruiqi Dong (Jira)" <ji...@apache.org> on 2026/06/03 08:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20659) MirrorMaker Checkpoint and Heartbeat records can accept unsupported versions when assertions are disabled - posted by "Ruiqi Dong (Jira)" <ji...@apache.org> on 2026/06/03 09:00:00 UTC, 0 replies.
- Re: [PR] MINOR: Correcting reviewers script for names [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/03 11:27:45 UTC, 1 replies.
- [PR] MINOR: Make VerifiableConsumer close timeout configurable [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/03 11:53:32 UTC, 6 replies.
- Re: [PR] KAFKA-20640: Consumer group accepts new classic members when migration policy is disabled [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/03 12:55:52 UTC, 6 replies.
- [PR] MINOR: Reduce unnecessary offset reads during log recovery [kafka] - posted by "pratx08 (via GitHub)" <gi...@apache.org> on 2026/06/03 13:42:21 UTC, 1 replies.
- [PR] MINOR: improve ListDeserializer [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/03 15:29:03 UTC, 4 replies.
- [PR] KAFKA-20621: Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/03 15:47:28 UTC, 8 replies.
- [PR] MINOR: improve AssignmentInfo [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/03 15:51:05 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20634) Spurious HighWatermarkUpdate failed errors in the group coordinator after partition leadership change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/03 16:13:00 UTC, 0 replies.
- [PR] KAFKA-20635: Spurious "Writing records..." failed errors in the group coordinator after partition leadership change [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/03 16:27:43 UTC, 11 replies.
- [jira] [Commented] (KAFKA-20651) Cache parsed KafkaPrincipal in StandardAcl.kafkaPrincipal() - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/03 17:02:00 UTC, 1 replies.
- [PR] KAFKA-12861: MockProducer NPE with default constructor [kafka] - posted by "dojeee (via GitHub)" <gi...@apache.org> on 2026/06/03 17:29:02 UTC, 6 replies.
- Re: [PR] KAFKA-13152: Add input.buffer.max.bytes based on KIP-770 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/06/03 19:13:28 UTC, 19 replies.
- [jira] [Commented] (KAFKA-20602) DLQ topic creation has 3 issues: indefinite hang, wrong log level, interrupt not restored - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/06/03 19:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20660) Add guardrail to detect use of legacy ConsumerRecords constructor via nextOffsets() - posted by "Evan Zhou (Jira)" <ji...@apache.org> on 2026/06/03 19:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/06/03 20:46:00 UTC, 0 replies.
- [PR] KAFKA-20660: Add detection of use of legacy ConsumerRecords(Map) constructor [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/06/03 21:06:34 UTC, 7 replies.
- [PR] KAFKA-20660: Mark deprecated ConsumerRecords constructor with forRemoval=true [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/06/03 21:07:42 UTC, 4 replies.
- Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (2/N) [kafka] - posted by "rajinisivaram (via GitHub)" <gi...@apache.org> on 2026/06/03 21:49:40 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20660) Add guardrail to detect use of legacy ConsumerRecords constructor via nextOffsets() - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/03 22:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/06/04 00:39:00 UTC, 0 replies.
- Re: [PR] MINOR: Add draft threat model + SECURITY.md + AGENTS.md for security-model discoverability [kafka] - posted by "potiuk (via GitHub)" <gi...@apache.org> on 2026/06/04 02:31:46 UTC, 5 replies.
- Re: [PR] KAFKA-20607: Include docs in version consistency checks and updates [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:35:59 UTC, 0 replies.
- Re: [PR] KAFKA-20628 Add TTL-based expiration to PartitionLeaderCache [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:36:00 UTC, 0 replies.
- Re: [PR] [PoC] KIP-1128: Replace KTable.transformValues with KTable.processFixedKey and add new KStreams.processFixedKey [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:36:01 UTC, 0 replies.
- Re: [PR] KAFKA-6786: Remove additional configs in StreamsBrokerDownResilienceTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 04:36:30 UTC, 1 replies.
- Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:08:09 UTC, 1 replies.
- Re: [PR] Update README.md [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:08:12 UTC, 1 replies.
- Re: [PR] KAFKA-19804: Improve heartbeat request manager initial HB interval [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:08:15 UTC, 0 replies.
- Re: [PR] KAFKA-19921 : Test-Common | Fixed order of arguments of assertEquals in unit tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/04 05:08:19 UTC, 1 replies.
- Re: [PR] KAFKA-18652: Add `acceptable.recovery.lag` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/04 05:47:46 UTC, 3 replies.
- Re: [PR] KSTREAMS-8781: Add back `rack.aware.assignment.tags` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/04 06:22:48 UTC, 13 replies.
- [jira] [Assigned] (KAFKA-20622) Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/04 10:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-20612: Stitch DLQ metrics with ShareGroupDLQStateManager. [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/04 10:50:00 UTC, 7 replies.
- [PR] MINOR: adding AGENTS.md and CLAUDE.md [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/06/04 12:04:46 UTC, 10 replies.
- [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka] - posted by "dojeee (via GitHub)" <gi...@apache.org> on 2026/06/04 12:05:52 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20610) Abstract ReplicaManager dependency from SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/06/04 12:09:00 UTC, 0 replies.
- [PR] Enhance MirrorMaker 2 with Fault Tolerance Capabilities [kafka] - posted by "VamsiKrishnaNandhyala (via GitHub)" <gi...@apache.org> on 2026/06/04 12:31:38 UTC, 3 replies.
- Re: [PR] KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG [kafka] - posted by "gaeljw (via GitHub)" <gi...@apache.org> on 2026/06/04 12:32:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/04 12:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20661) KRaft unavailability when controller are misconfigured - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/04 13:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/04 14:44:39 UTC, 6 replies.
- Re: [PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/06/04 14:54:22 UTC, 2 replies.
- Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/06/04 14:55:06 UTC, 0 replies.
- [PR] KAFKA-20641: ConsumerGroup should clean up the state when a static member temporarily leaves. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/04 15:07:44 UTC, 6 replies.
- [jira] [Updated] (KAFKA-20662) Proper error code for malformed request during online migration - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2026/06/04 15:56:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20662) Proper error code for malformed request during online migration - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2026/06/04 15:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-20145: Avoid redundant partial HB acks from network-thread reconcile [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/04 16:29:33 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/04 16:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/04 16:48:00 UTC, 0 replies.
- [PR] MINOR: Use Map for internal topic configs [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/06/04 16:54:54 UTC, 3 replies.
- Re: [PR] KAFKA-19620: Move AutoTopicCreationManager to server module [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/06/04 16:55:21 UTC, 0 replies.
- [PR] KAFKA-20362: Make reviewer-trailer auto-fill work on fork PRs [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/06/04 17:33:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/06/04 18:39:00 UTC, 1 replies.
- [PR] MINOR: Clarify active segment rolling for segment.bytes, segment.ms, and max.compaction.lag.ms [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/06/04 18:55:26 UTC, 0 replies.
- [jira] [Created] (KAFKA-20664) Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/06/04 19:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20655) Mark KIP-1331 RPCs stable before release - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/04 19:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/04 19:17:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20664) Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/04 19:18:00 UTC, 0 replies.
- [PR] Kip 1340 poc [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/06/04 19:42:10 UTC, 1 replies.
- [PR] KAFKA-20663: Stale persisted changelog offset causes OffsetOutOfRangeExceptionAdd commit interval to prevent stale changelog offsets [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/04 19:51:04 UTC, 0 replies.
- Re: [PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka] - posted by "josefk31 (via GitHub)" <gi...@apache.org> on 2026/06/04 21:18:03 UTC, 25 replies.
- [PR] KAFKA-20613: Add code to support copy record in DLQ state manager. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/04 22:15:11 UTC, 34 replies.
- [jira] [Reopened] (KAFKA-20613) Copy original record data in DLQ records - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/04 22:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20613) Copy original record data in DLQ records - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/04 22:45:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20549) Implementation of Share Group DLQ Manager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/04 22:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20612) Share group DLQ metrics - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/04 22:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20611) Integration of dlq manager with QFK code - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/04 22:46:00 UTC, 0 replies.
- Re: [PR] KAFKA-10357: Add explicit internal topic initialization for Kafka Str… [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/06/04 23:13:45 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20665) Add warmup task support to reconciler - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/05 01:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20665) Add warmup task support to reconciler - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/05 01:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka] - posted by "ChoMinGi (via GitHub)" <gi...@apache.org> on 2026/06/05 04:34:30 UTC, 0 replies.
- Re: [PR] KAFKA-18157: Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:35:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/06/05 04:41:00 UTC, 0 replies.
- Re: [PR] Update EndToEndLatency.java [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:59:46 UTC, 1 replies.
- Re: [PR] Add ZSTD compression configuration options [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/05 04:59:54 UTC, 0 replies.
- [jira] [Created] (KAFKA-20666) Connect offset backing stores serialize ByteBuffer.array() instead of the buffer's remaining bytes - posted by "Ruiqi Dong (Jira)" <ji...@apache.org> on 2026/06/05 05:31:00 UTC, 0 replies.
- Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/06/05 07:24:47 UTC, 1 replies.
- [PR] MINOR: Cleanup DLQ record parameter. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/05 08:00:12 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-20651) Cache parsed KafkaPrincipal in StandardAcl.kafkaPrincipal() - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/05 08:20:00 UTC, 2 replies.
- Re: [PR] KAFKA-20616: Close offsets-CF ColumnFamilyOptions and ensure CF handles are releas… [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/05 09:34:04 UTC, 7 replies.
- [jira] [Commented] (KAFKA-20541) Duplicate generated folder in kafka-site - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/06/05 09:45:00 UTC, 10 replies.
- Re: [PR] KAFKA-15038: Remove topicIdByPartitionMap from RemoteLogManager [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/06/05 10:28:59 UTC, 0 replies.
- [PR] KAFKA-19404: Align Connect plugin.path docs with actual behavior [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/05 12:02:31 UTC, 2 replies.
- Re: [PR] KAFKA-20597: Fix prefixScan overflow handling in in-memory state stores [kafka] - posted by "pchintar (via GitHub)" <gi...@apache.org> on 2026/06/05 12:03:19 UTC, 0 replies.
- [PR] KAFKA-20651: Cache parsed KafkaPrincipal in StandardAcl (#v1) [kafka] - posted by "Chhida (via GitHub)" <gi...@apache.org> on 2026/06/05 13:20:25 UTC, 3 replies.
- [PR] MINOR: Fix non-idiomatic builder usage in TargetAssignmentBuilderTest [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:20:40 UTC, 3 replies.
- [PR] MINOR: Fix TargetAssignmentBuilderBenchmark [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:20:54 UTC, 1 replies.
- [PR] KAFKA-20292 [1/N]: Prepare to split TargetAssignmentBuilders [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:44:25 UTC, 5 replies.
- [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:44:35 UTC, 5 replies.
- [PR] KAFKA-20292 [5/N]: Add TargetAssignmentRecordsBuilder [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:44:49 UTC, 3 replies.
- [PR] WIP: KAFKA-20292: Handle membership changes during offloaded assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:46:14 UTC, 1 replies.
- Re: [PR] KAFKA-20664: Clarify active segment rolling for segment.bytes, segment.ms, and max.compaction.lag.ms [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/06/05 14:46:19 UTC, 0 replies.
- [PR] KAFKA-20664: Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/06/05 14:47:48 UTC, 0 replies.
- Re: [PR] KAFKA-20292 [2/N]: Handle membership changes during offloaded streams assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:48:05 UTC, 1 replies.
- Re: [PR] KAFKA-20292 [1/N]: Handle membership changes during offloaded assignments [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/05 14:48:07 UTC, 1 replies.
- [jira] [Created] (KAFKA-20667) O(N) ACL scan in StandardAuthorizerData.checkSection - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/05 15:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/06/05 15:09:29 UTC, 1 replies.
- Re: [PR] KAFKA-20663: Stale persisted changelog offset causes OffsetOutOfRangeExceptionAdd [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/05 15:12:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20667) O(N) ACL scan in StandardAuthorizerData.checkSection - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/05 15:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20667) O(N) ACL scan in StandardAuthorizerData.checkSection - posted by "ibenchhida (Jira)" <ji...@apache.org> on 2026/06/05 15:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/06/05 16:34:00 UTC, 1 replies.
- [PR] KAFKA-20663: Fix startup state manager close to release StateDirectory task lock [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/05 16:36:35 UTC, 4 replies.
- [PR] KAFKA-20663: Return committed offset from newest segment first [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/05 16:37:26 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they match - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/06/05 17:00:00 UTC, 3 replies.
- [PR] KAFKA-20644: Fail fast when admin.listeners overlaps listeners [kafka] - posted by "PavelZeger (via GitHub)" <gi...@apache.org> on 2026/06/05 17:26:49 UTC, 1 replies.
- [jira] [Created] (KAFKA-20668) Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/05 17:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20668) Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/05 18:00:00 UTC, 2 replies.
- [PR] KAFKA-XXXXX: AdminClient partition-leader APIs hang until default.api.timeout.ms when a cached leader has left the cluster [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/05 18:54:37 UTC, 2 replies.
- Re: [PR] KAFKA-20664: Improve docs about "max compaction lag", "segment.ms" and "segment.bytes" with regard to active segment rolling [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/06/05 19:19:03 UTC, 2 replies.
- [jira] [Updated] (KAFKA-18652) Extended set of streams-specific broker configurations - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/05 20:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18652) Extended set of streams-specific broker configurations - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/05 20:51:00 UTC, 0 replies.
- Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/05 23:49:16 UTC, 7 replies.
- Re: [PR] KAFKA-19536: Respect grace period for out-of-order stream joins [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 04:27:38 UTC, 0 replies.
- Re: [PR] KAFKA-20235: Replace System.out.println with proper logger for missing property file warning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/06 04:48:04 UTC, 1 replies.
- [PR] KAFKA-20668: Add --checkpoint option to kafka-metadata-shell [kafka] - posted by "oneby-wang (via GitHub)" <gi...@apache.org> on 2026/06/06 14:24:45 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-18209) Cleanup __transaction_state config logic - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/06 15:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-16263: Add listeners and callbacks section to Streams developer guide [kafka] - posted by "minjcho (via GitHub)" <gi...@apache.org> on 2026/06/06 17:25:38 UTC, 5 replies.
- [PR] KAFKA-20657: Fix JsonConverter ByteBuffer BYTES serialization [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/06 21:49:37 UTC, 1 replies.
- Re: [PR] KAFKA-18862: Consolidate shared heartbeat request manager tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 04:36:13 UTC, 7 replies.
- Re: [PR] KAFKA-20602: Bound DLQ topic creation, fix log level and restore interrupt in DeadLetterQueueReporter [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 04:36:16 UTC, 0 replies.
- Re: [PR] KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 05:03:03 UTC, 1 replies.
- Re: [PR] KAFKA-19963: Add more information to doc to explain how to parallelize per topic with Kafka Streams [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 05:03:06 UTC, 0 replies.
- Re: [PR] Rlm [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/07 05:03:14 UTC, 0 replies.
- [PR] Fix typo in Checkstyle GitHub Actions helper script [kafka] - posted by "ganeshvenkatasai (via GitHub)" <gi...@apache.org> on 2026/06/07 11:29:59 UTC, 0 replies.
- Re: [PR] MINOR: Note that formatted storage directories are not forward-compatible [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/07 11:54:18 UTC, 0 replies.
- [PR] MINOR: Remove unused maybeEmitMetric from MetricsEmitter [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/07 14:29:30 UTC, 1 replies.
- Re: [PR] MINOR: Fix typo in Checkstyle GitHub Actions helper script [kafka] - posted by "ganeshvenkatasai (via GitHub)" <gi...@apache.org> on 2026/06/07 15:13:22 UTC, 7 replies.
- Re: [PR] MINOR: Enable testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl f… [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/07 15:34:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-20669) Fix Consumer propagates stale TopicAuthorizationException/InvalidTopicException after subscription change - posted by "KC.H (Jira)" <ji...@apache.org> on 2026/06/07 15:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20669) Fix Consumer propagates stale TopicAuthorizationException/InvalidTopicException after subscription change - posted by "KC.H (Jira)" <ji...@apache.org> on 2026/06/07 15:54:00 UTC, 0 replies.
- Re: [PR] KAFKA-20669: Fix Consumer propagates stale TopicAuthorizationException/InvalidTopicException after subscription change [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/07 16:08:56 UTC, 6 replies.
- Re: [PR] KAFKA-20125: Improve the docs of dynamic-only configurations [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/07 16:11:36 UTC, 2 replies.
- [PR] KAFKA-20196: Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics [kafka] - posted by "Rancho-7 (via GitHub)" <gi...@apache.org> on 2026/06/07 16:20:42 UTC, 9 replies.
- [PR] KAFKA-16337: removed deprecated apis [kafka] - posted by "Samrev (via GitHub)" <gi...@apache.org> on 2026/06/07 16:40:43 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20670) Remove kafka-streams-scala module - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20670) Remove kafka-streams-scala module - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20671) Remove config `processing.exception.handler.global.enabled` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20671) Remove config `processing.exception.handler.global.enabled` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-18495) Remove Invalid 'numberOfOpenFiles' Metric from RocksDB State Store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19557) Remove BrokerNotFoundException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/07 20:13:00 UTC, 0 replies.
- [PR] MINOR: Truncate cluster.json when generating in ducker-ak [kafka] - posted by "amandayclee (via GitHub)" <gi...@apache.org> on 2026/06/07 23:49:08 UTC, 3 replies.
- Re: [PR] MINOR: Add generic config type to BrokerReconfigurable [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/06/08 01:36:24 UTC, 3 replies.
- Re: [PR] KAFKA-7493: Remove obsolete controller bounce-at-start Streams test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:37:33 UTC, 2 replies.
- Re: [PR] KAFKA-19193: trace-log rack-specific load stats in rack-aware mode [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:37:35 UTC, 1 replies.
- Re: [PR] KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:37:37 UTC, 1 replies.
- Re: [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:37:40 UTC, 4 replies.
- Re: [PR] KAFKA-20642: Support character ranges in Kafka shell globs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 04:37:44 UTC, 4 replies.
- Re: [PR] KAFKA-19631 Admin#describeReplicaLogDirs does not handle error correctly [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 05:06:16 UTC, 0 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - client (4/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/08 05:06:20 UTC, 1 replies.
- Re: [PR] KAFKA-20362: Make reviewer-trailer auto-fill work on all contributors and comments [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/08 07:18:28 UTC, 3 replies.
- Re: [PR] KAFKA-20617: add validation for cluster-id in Formatter [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/06/08 07:34:53 UTC, 13 replies.
- [PR] KAFKA-20088 CIDR-based Host Patterns for ACLs [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/06/08 08:10:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-20672) Handle ARCHIVING records in share partition initialize - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/08 08:12:00 UTC, 0 replies.
- [PR] KAFKA-20672: Retry DLQ on SharePartition init for ARCHIVING records. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/08 08:47:12 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-20668) Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot - posted by "Oneby Wang (Jira)" <ji...@apache.org> on 2026/06/08 09:56:00 UTC, 0 replies.
- [PR] KAFKA-20658: Fix Cast ByteBuffer BYTES to string encoding [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/08 11:57:48 UTC, 1 replies.
- [PR] KAFKA-20659: Reject unsupported MirrorMaker record versions at runtime [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/08 12:22:08 UTC, 3 replies.
- [PR] MINOR; Refactor KRaft API around message handling [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/06/08 12:54:39 UTC, 52 replies.
- Re: [PR] MINOR: Remove unused Response.onComplete method [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/08 12:55:36 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-17689) Migrate TieredStorageTestHarness to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/08 13:26:00 UTC, 0 replies.
- Re: [PR] MINOR: Batch ExpiringErrorCache updates and cleanup [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/08 14:28:12 UTC, 1 replies.
- [PR] KAFKA-20663: Fix startup state manager close to release StateDirectory task lock (#22490) - 4.3 backport [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/08 14:42:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20635) Spurious "Writing records..." failed errors in the group coordinator after partition leadership change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/08 15:01:00 UTC, 0 replies.
- Re: [PR] KAFKA-17840: Move ClientRequestQuotaManager to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/08 15:23:02 UTC, 15 replies.
- [PR] KAFKA-20292 [3/N]: Lift member updates out of consumer and share TargetAssignmentBuilder [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/08 15:25:06 UTC, 9 replies.
- [jira] [Created] (KAFKA-20673) AdminClient partition-leader APIs hang when a cached leader has left the cluster - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/08 15:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20673) AdminClient partition-leader APIs hang when a cached leader has left the cluster - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/08 15:47:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/06/08 15:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/06/08 16:00:00 UTC, 0 replies.
- [PR] KAFKA-20622: Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/08 16:15:13 UTC, 15 replies.
- [jira] [Commented] (KAFKA-20673) AdminClient partition-leader APIs hang when a cached leader has left the cluster - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/08 16:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-20673: AdminClient partition-leader APIs hang when a cached leader has left the cluster [kafka] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/06/08 16:21:09 UTC, 8 replies.
- [jira] [Updated] (KAFKA-20675) Remove methods deprecated by KIP-1035 - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/08 16:29:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-20675) Remove methods deprecated by KIP-1035 - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/08 16:29:00 UTC, 0 replies.
- Re: [PR] KAFKA-20635: Spurious "Writing records..." failed errors in the group coordinator after partition leadership change (4.0) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/08 16:41:00 UTC, 2 replies.
- [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/08 17:22:51 UTC, 16 replies.
- Re: [PR] KAFKA-20635: Spurious "Writing records..." failed errors in the group coordinator... (4.2) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/08 18:43:58 UTC, 0 replies.
- Re: [PR] KAFKA-20635: Spurious "Writing records..." failed errors in the group coordinator... (4.1) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/08 18:44:53 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20635) Spurious "Writing records..." failed errors in the group coordinator after partition leadership change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/08 18:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20676) Broker fails to start when ssl.cipher.suites contains ciphers unavailable in the JSSE provider - posted by "Gergely Harmadás (Jira)" <ji...@apache.org> on 2026/06/08 22:47:00 UTC, 0 replies.
- [PR] KAFKA-20676: do not fail startup when a non-supported user configured cipher is used [kafka] - posted by "harmadasg (via GitHub)" <gi...@apache.org> on 2026/06/08 23:16:44 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-14276) Clarify java doc for ProcessorAPI init method and stateStore.approximateNumEntries() - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 00:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-18735: Return null from ConfigEntity.name() for default quotas [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/06/09 01:06:25 UTC, 1 replies.
- [PR] MINOR: improve byte[] array size bounds check [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/09 01:21:44 UTC, 14 replies.
- [jira] [Created] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/09 02:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/06/09 02:36:00 UTC, 1 replies.
- Re: [PR] KAFKA-17821: the set of configs displayed by `logAll` could be invalid [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:29 UTC, 0 replies.
- Re: [PR] KAFKA-19010: Added JVM argument to default configuration [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:33 UTC, 1 replies.
- Re: [PR] KAFKA-19782: improve Authorizer by using (Patricia) trie [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:36 UTC, 1 replies.
- Re: [PR] KAFKA-19947 Add Unit test coverage for KafkaCSVMetricsReporter [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:39 UTC, 1 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - protocol and server (1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:40 UTC, 1 replies.
- Re: [PR] MM2: Implement Fault Tolerance for Log Truncation and Topic Reset [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:44 UTC, 1 replies.
- Re: [PR] fix: replace printStackTrace() with proper logging in KafkaStreamsNamedTopologyWrapper [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/09 04:53:49 UTC, 1 replies.
- [PR] Enhance MirrorSourceTask with log truncation detection and topic reset recovery [kafka] - posted by "bhavna2004 (via GitHub)" <gi...@apache.org> on 2026/06/09 06:15:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/09 07:43:00 UTC, 0 replies.
- Re: [PR] MINOR: Add `TieredStorageTestPlan` as the execution wrapper created by `TieredStorageTestBuilder.build()` [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/09 08:32:16 UTC, 15 replies.
- Re: [PR] KAFKA-17164: Enforce 'application.server' : format at config level. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/09 10:16:52 UTC, 7 replies.
- Re: [PR] KAFKA-17251: Avoid WARN on cleanup when state directory only contains process metadata. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/09 10:17:42 UTC, 4 replies.
- [jira] [Created] (KAFKA-20678) Analyze and impl fetch from remote storage for DLQ - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/09 10:27:00 UTC, 0 replies.
- [PR] KAFKA-20451: Move RequestChannel Responses to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/09 10:44:17 UTC, 0 replies.
- [PR] MINOR: Update MetadataVersionTest properly [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/06/09 11:27:16 UTC, 7 replies.
- Re: [PR] KAFKA-20587: Wait for global store topic partitions in test setup [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:00:51 UTC, 1 replies.
- Re: [PR] KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:01:25 UTC, 1 replies.
- Re: [PR] KAFKA-18812: Improve consumer API errors upon background thread failure [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:02:09 UTC, 13 replies.
- Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:02:59 UTC, 1 replies.
- Re: [PR] KAFKA-20389: Filter internal keys from connector plugin config REST response [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/09 12:05:28 UTC, 0 replies.
- Re: [PR] MINOR: Fix delegation token docs typo [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/09 12:50:32 UTC, 0 replies.
- Re: [PR] MINOR: Fixed typos in comments across multiple Java classes [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/09 12:51:58 UTC, 0 replies.
- Re: [PR] introduce private method to remove clones [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/09 12:52:55 UTC, 0 replies.
- [PR] MINOR: Tweak examples readme [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/09 13:16:33 UTC, 1 replies.
- [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/06/09 13:20:33 UTC, 8 replies.
- [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/09 13:48:11 UTC, 9 replies.
- [PR] MINOR: fix supress warnings in ConsumerRecordsTest [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/06/09 14:08:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-20679) Remove deprecated Yammer-based group coordinator metrics - posted by "Nick Guo (Jira)" <ji...@apache.org> on 2026/06/09 14:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/09 14:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20680) Prevent stale revocation state when Streams static member temporarily leaves - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/06/09 14:34:00 UTC, 0 replies.
- [PR] KAFKA-20444: [12/12] Mark TxnOffsetCommit v6 as stable (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/09 14:45:03 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20672) Handle ARCHIVING records in share partition initialize - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/06/09 15:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/09 15:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/09 15:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-17871) Source task source offset reads can block herder task cancellation - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/06/09 16:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/09 17:31:00 UTC, 0 replies.
- [PR] KAFKA-20681: Consolidate heartbeat success handling for consumer and share [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/09 17:40:52 UTC, 1 replies.
- [jira] [Created] (KAFKA-20682) Implement IQv2 for headers-aware state stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/09 18:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20682) Implement IQv2 for headers-aware state stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/09 19:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20682) Implement IQv2 for headers-aware state stores - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/06/09 19:16:00 UTC, 2 replies.
- [PR] MINOR: update AK/KS doc to [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/06/09 19:50:46 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20679) Remove deprecated Yammer-based group coordinator metrics - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/09 20:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20680) Prevent stale revocation state when Streams static member temporarily leaves - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 22:54:00 UTC, 0 replies.
- [PR] MINOR: Add additional documentation for KIP-1035 [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/09 22:57:41 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 23:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20683) Add broker side custom assignors for "streams" groups - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 23:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20683) Add broker side custom assignors for "streams" groups - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 23:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20683) Add broker side custom assignors for "streams" groups - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/09 23:49:00 UTC, 0 replies.
- Re: [PR] MINOR: make processMessages task outputs relocatable for build cache [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 05:00:58 UTC, 3 replies.
- Re: [PR] KAFKA-20207: handle the ClusterIdRecord as part of the metadata image [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/10 05:00:59 UTC, 1 replies.
- Re: [PR] MINOR: fix suppress warnings in ConsumerRecordsTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/10 08:36:48 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20078) Remove `Exit.exit` from `tools - posted by "Chih-Yuan Chien (Jira)" <ji...@apache.org> on 2026/06/10 09:57:00 UTC, 0 replies.
- [PR] Update upgrade.md in the notable changes introduced in 4.4.0 section for | KAFKA-20223: Extended I/O Metrics Collection [kafka] - posted by "sahildevgon (via GitHub)" <gi...@apache.org> on 2026/06/10 10:22:25 UTC, 0 replies.
- [PR] MINOR: Remove hamcrest from storage [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/10 10:27:14 UTC, 7 replies.
- [PR] KAFKA-20673: Skip stale-leader lookup retry while the AdminClient is closing (follow-up) [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/10 10:33:58 UTC, 2 replies.
- Re: [PR] Minor : Update the AK doc to include changes in KIP-1291 [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/10 11:43:57 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 13:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/10 13:11:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/10 13:11:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/10 13:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20655) Mark KIP-1331 RPCs stable before release - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/10 13:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20655) Mark KIP-1331 RPCs stable before release - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/10 13:36:00 UTC, 1 replies.
- Re: [PR] KAFKA-20640: Consumer group should reject classic member joins when migration policy is disabled [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/10 13:51:56 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/10 14:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20444) Align TxnOffsetCommit API with OffsetCommit API (KIP-1319) - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/10 14:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/10 14:36:15 UTC, 0 replies.
- [PR] MINOR: remove no-op call when HB fails and member already unsubscribed [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/10 14:50:44 UTC, 2 replies.
- [PR] [WIP] KAFKA-18775: Simplifying Add/Remove Voter in MetadataQuorumCommand [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/06/10 15:50:48 UTC, 0 replies.
- [PR] KAFKA-20667: Add principal-level index to AclCache to fix O(N) ACL sc… [kafka] - posted by "Chhida (via GitHub)" <gi...@apache.org> on 2026/06/10 15:54:56 UTC, 1 replies.
- [PR] KAFKA-20657: JsonConverter BYTES uses ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/06/10 16:00:48 UTC, 1 replies.
- Re: [PR] KAFKA-20232: Fix WakeupException in awaitMetadataUpdate() [kafka] - posted by "Baisang (via GitHub)" <gi...@apache.org> on 2026/06/10 16:03:48 UTC, 4 replies.
- [PR] KAFKA-20658: Cast SMT honors ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/06/10 16:16:11 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 16:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 16:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 16:22:00 UTC, 0 replies.
- [PR] KAFKA-20666: Offset backing stores honor ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/06/10 16:22:41 UTC, 1 replies.
- [PR] KAFKA-20656: Struct honors ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/06/10 16:26:27 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/06/10 16:35:00 UTC, 0 replies.
- [PR] MINOR: Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer [kafka] - posted by "Russole (via GitHub)" <gi...@apache.org> on 2026/06/10 16:40:48 UTC, 3 replies.
- Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/10 16:53:21 UTC, 43 replies.
- [jira] [Created] (KAFKA-20684) Add Deprecated anno for ConsumerRebalanceListener class/methods - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/06/10 17:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20684) Add Deprecated anno for ConsumerRebalanceListener class/methods - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/06/10 17:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18862) Review testHeartbeatResponseOnErrorHandling duplicate logic in ShareHeartbeatRequestManagerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 18:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18862) Review testHeartbeatResponseOnErrorHandling duplicate logic in ShareHeartbeatRequestManagerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/10 18:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20652) Improve/Fix java docs - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/10 18:15:00 UTC, 0 replies.
- [PR] MINOR: Clarify consumer behaviour on partition pause & re-assignments [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/10 18:53:47 UTC, 3 replies.
- [PR] Revert "KAFKA-20617: add validation for cluster-id in Formatter (#22384)" [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/06/10 19:08:38 UTC, 1 replies.
- [PR] Update and align broker/group config "importance" levels (KIP-848/1071/932) [kafka] - posted by "suzhiking (via GitHub)" <gi...@apache.org> on 2026/06/10 20:53:24 UTC, 1 replies.
- [PR] Update and align broker/group config "importance" levels (KIP-848/107… [kafka] - posted by "suzhiking (via GitHub)" <gi...@apache.org> on 2026/06/10 21:04:22 UTC, 0 replies.
- Re: [PR] KAFKA-20385 [3/N]: Integration tests + examples [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/06/10 21:27:49 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/10 22:37:00 UTC, 0 replies.
- Re: [PR] MINOR: Update and align broker/group config "importance" levels (KIP-848/107… [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/10 22:55:08 UTC, 2 replies.
- Re: [PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:03:44 UTC, 1 replies.
- Re: [PR] (WIP) KAFKA-17243:MetadataQuorumCommand describe to include CommittedVoters [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:03:47 UTC, 1 replies.
- Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:03:51 UTC, 0 replies.
- Re: [PR] MINOR: Add java version check command to README [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:03:57 UTC, 1 replies.
- Re: [PR] KAFKA-20099: Clarify how stream-time works in the docs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:04:00 UTC, 1 replies.
- Re: [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/11 05:04:07 UTC, 0 replies.
- Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/06/11 06:04:43 UTC, 8 replies.
- Re: [PR] MINOR: fix suppress warnings in ConsumerRecordsTest and KafkaProducerTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/11 09:05:23 UTC, 0 replies.
- Re: [PR] KAFKA-20078: Remove `Exit.exit` from `tools` [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/06/11 09:08:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20369) Upgrade log4j2 from 2.25.3 to 2.25.4 - posted by "Manikumar (Jira)" <ji...@apache.org> on 2026/06/11 10:58:00 UTC, 0 replies.
- [PR] MINOR: Fix missing parenthesis in under-min-ISR trace log [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/06/11 12:10:41 UTC, 12 replies.
- [jira] [Commented] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/11 14:18:00 UTC, 1 replies.
- [PR] MINOR: Share common implementation for downstream offset translation boundary in MirrorMaker offset syncs [kafka] - posted by "Russole (via GitHub)" <gi...@apache.org> on 2026/06/11 14:35:53 UTC, 3 replies.
- Re: [PR] MINOR: Assert queryable state range results [kafka] - posted by "codingkiddo (via GitHub)" <gi...@apache.org> on 2026/06/11 14:47:09 UTC, 0 replies.
- [PR] KAFKA-20623: Wire topology description plugin into GroupCoordinatorService [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/11 15:28:38 UTC, 4 replies.
- [PR] MINOR: Fix grammatical typos in raft module messages [kafka] - posted by "gaoxiaolei-s59 (via GitHub)" <gi...@apache.org> on 2026/06/11 15:29:09 UTC, 1 replies.
- [jira] [Created] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/11 17:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/11 17:54:00 UTC, 4 replies.
- [PR] MINOR: improve ListDeserializer exception [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/11 18:23:01 UTC, 3 replies.
- [jira] [Created] (KAFKA-20686) DLQ integ tests - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/11 19:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20686) DLQ integ tests - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/11 19:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/11 19:42:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/11 20:42:00 UTC, 0 replies.
- [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for connect:runtime [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/12 00:22:27 UTC, 4 replies.
- Re: [PR] Add explicit least-privilege permissions to GitHub workflows [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 04:36:07 UTC, 0 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - client (2/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 05:07:29 UTC, 1 replies.
- Re: [PR] KAFKA-20201: Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/12 05:07:33 UTC, 1 replies.
- [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka] - posted by "zoro30102000 (via GitHub)" <gi...@apache.org> on 2026/06/12 07:20:18 UTC, 2 replies.
- [jira] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/12 07:30:00 UTC, 0 replies.
- [PR] MINOR: Fix spotless import order violation in OAuthBearerValidatorCallbackHandlerTest [kafka] - posted by "gaoxiaolei-s59 (via GitHub)" <gi...@apache.org> on 2026/06/12 08:36:40 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/12 09:46:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/12 09:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/12 09:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/12 12:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/12 13:33:00 UTC, 0 replies.
- [PR] docs: add Oxford comma in README.md project list [kafka] - posted by "koteshyelamati (via GitHub)" <gi...@apache.org> on 2026/06/12 13:39:32 UTC, 2 replies.
- [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/12 13:59:33 UTC, 8 replies.
- [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/12 14:28:49 UTC, 16 replies.
- [PR] KAFKA-19753: Fix duplicated topic metrics in FetchMetricsManager for topic names containing dots [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/12 14:55:00 UTC, 1 replies.
- [PR] KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/12 15:03:30 UTC, 3 replies.
- [PR] MINOR: Add release related paths to .gitignore [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/12 16:11:40 UTC, 1 replies.
- [jira] [Created] (KAFKA-20687) Consider improving unused chunks reuse when no data written - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/12 18:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/12 19:22:32 UTC, 1 replies.
- [jira] [Created] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/06/12 22:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/06/12 22:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/12 22:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/12 22:22:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams - posted by "Gavin Wang (Jira)" <ji...@apache.org> on 2026/06/12 22:33:00 UTC, 0 replies.
- [PR] MINOR: Add 4.2.1 to system tests [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/12 23:44:42 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/13 00:21:00 UTC, 0 replies.
- [PR] KAFKA-20688: Fix RocksDB memory leak [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/13 00:32:29 UTC, 3 replies.
- [PR] KAFKA-19902: fix(consumer): use latest leader epoch when committing offsets [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/13 02:04:33 UTC, 1 replies.
- [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/13 02:33:15 UTC, 15 replies.
- [PR] KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/13 02:36:27 UTC, 3 replies.
- [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/06/13 03:06:35 UTC, 6 replies.
- [PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/13 03:54:35 UTC, 4 replies.
- Re: [PR] KAFKA-20379: ducker-ak has no option to skip the gradlew systemTestLibs build step [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/13 04:11:06 UTC, 0 replies.
- [PR] MINOR: Followup Add KIP-1284 into streams document [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/06/13 04:24:01 UTC, 0 replies.
- Re: [PR] KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/13 05:01:42 UTC, 1 replies.
- Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/06/13 12:26:34 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/13 13:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/13 13:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/13 13:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/13 13:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/13 13:38:00 UTC, 0 replies.
- [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/13 13:54:22 UTC, 4 replies.
- Re: [PR] KAFKA-2341 Add standard deviation as metric [kafka] - posted by "likandia (via GitHub)" <gi...@apache.org> on 2026/06/13 14:01:05 UTC, 0 replies.
- [PR] MINOR: Fix typos in comments and exception messages [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/06/13 14:41:33 UTC, 2 replies.
- [PR] updated request metrics documentation to apply for all APIs [kafka] - posted by "Samrev (via GitHub)" <gi...@apache.org> on 2026/06/13 16:47:52 UTC, 3 replies.
- Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka] - posted by "jack2012aa (via GitHub)" <gi...@apache.org> on 2026/06/13 17:23:03 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/13 23:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-20384: Add a unit test for reproducing per-record context [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/06/14 03:19:27 UTC, 0 replies.
- Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 04:37:20 UTC, 1 replies.
- Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 05:08:39 UTC, 1 replies.
- Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/14 05:08:50 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment - posted by "Shlomit (Jira)" <ji...@apache.org> on 2026/06/14 10:21:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment - posted by "Shlomit (Jira)" <ji...@apache.org> on 2026/06/14 10:22:00 UTC, 3 replies.
- [PR] KAFKA-19919: Avoid reverse DNS for built-in SASL servers [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/06/14 11:07:13 UTC, 5 replies.
- Re: [PR] MINOR: Fix Streams query result Javadocs [kafka] - posted by "pony-maggie (via GitHub)" <gi...@apache.org> on 2026/06/14 12:38:50 UTC, 0 replies.
- [jira] [Created] (KAFKA-20689) Remove unnecessary Hamcrest dependency from tools module - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/06/14 16:19:00 UTC, 0 replies.
- [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/06/14 16:20:40 UTC, 11 replies.
- [jira] [Created] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 17:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 17:39:00 UTC, 0 replies.
- [PR] KAFKA-20690: silent test-coverage hole in PersisterStateBatchCombinerTest [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/14 17:39:35 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 17:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n²) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 17:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n^2) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 17:57:00 UTC, 4 replies.
- [PR] KAFKA-20691: PersisterStateBatchCombiner.combineStateBatches() with an event-driven sweep-line [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/14 18:16:33 UTC, 8 replies.
- [jira] [Commented] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n^2) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/14 18:23:00 UTC, 1 replies.
- Re: [PR] KAFKA-19008 Remove scala version from artifacts [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:15:23 UTC, 1 replies.
- Re: [PR] KAFKA-19262 Add a test to verify all metrics naming pattern [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:15:25 UTC, 1 replies.
- Re: [PR] KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:15:27 UTC, 1 replies.
- Re: [PR] KAFKA-17798: Add forbidden-apis linting to gradle build [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:15:31 UTC, 1 replies.
- Re: [PR] MINOR: Add MockProducer and MockConsumer testing examples [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/15 05:15:32 UTC, 1 replies.
- [PR] KAFKA-13716: Add unit tests for DeleteRecordsCommand [kafka] - posted by "Dpk376 (via GitHub)" <gi...@apache.org> on 2026/06/15 06:44:13 UTC, 3 replies.
- Re: [PR] KAFKA-18998: Move AuthHelper to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/15 07:01:41 UTC, 8 replies.
- [PR] KAFKA-8035: Add lambda and anonymous class tests for KStream API generics [kafka] - posted by "Dpk376 (via GitHub)" <gi...@apache.org> on 2026/06/15 07:20:46 UTC, 2 replies.
- [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka] - posted by "aravind-kvs (via GitHub)" <gi...@apache.org> on 2026/06/15 07:28:21 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/06/15 07:30:00 UTC, 0 replies.
- [PR] MINOR: Move transaction coordinator leaf classes from Scala to Java [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/06/15 07:34:23 UTC, 7 replies.
- Re: [PR] KAFKA-20637: Move ForwardingManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/15 08:20:38 UTC, 4 replies.
- Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/15 08:42:08 UTC, 5 replies.
- [jira] [Commented] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic - posted by "Ketha Aravind (Jira)" <ji...@apache.org> on 2026/06/15 09:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning - posted by "Harikrishnan (Jira)" <ji...@apache.org> on 2026/06/15 12:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20692) Add unit tests for ToolsUtils - posted by "Deepak Kumar S S (Jira)" <ji...@apache.org> on 2026/06/15 12:27:00 UTC, 0 replies.
- Re: [PR] KAFKA-20610: Added abstraction classes for share fetch reads (1/N) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/15 12:29:28 UTC, 2 replies.
- [PR] KAFKA-20692: Add unit tests for ToolsUtils [kafka] - posted by "Dpk376 (via GitHub)" <gi...@apache.org> on 2026/06/15 12:29:55 UTC, 2 replies.
- [PR] KAFKA-20377: Add to pass additional Docker build arguments in the system tests [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/06/15 13:04:41 UTC, 5 replies.
- Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/15 13:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20377) ducker-ak does not support passing additional Docker build arguments - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/06/15 13:41:00 UTC, 0 replies.
- [PR] MINOR: Remove unnecessary Hamcrest dependency from tools module [kafka] - posted by "Russole (via GitHub)" <gi...@apache.org> on 2026/06/15 14:06:51 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/15 14:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20693) NPE in error handling in AbstractHerder - posted by "Gaetan Collaud (Jira)" <ji...@apache.org> on 2026/06/15 14:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20693) NPE in error handling in AbstractHerder - posted by "Gaetan Collaud (Jira)" <ji...@apache.org> on 2026/06/15 14:49:00 UTC, 6 replies.
- [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/15 14:52:06 UTC, 4 replies.
- [jira] [Created] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/15 15:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/06/15 15:58:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20637) Move ForwardingManager to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/15 16:03:00 UTC, 0 replies.
- [PR] Fix share read leader epoch sentinel [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/15 16:03:59 UTC, 1 replies.
- [PR] MINOR: Migrate SaslClientsWithInvalidCredentialsTest to ClusterInstance [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/15 16:07:24 UTC, 1 replies.
- [jira] [Created] (KAFKA-20695) Extend "describe group" to return "task offset" metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/15 16:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20695) Extend "describe group" to return "task offset" metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/15 16:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20696) Periodic plugin.deleteTopology cleanup for naturally-expired streams groups - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/06/15 16:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20696) Periodic plugin.deleteTopology cleanup for naturally-expired streams groups - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/06/15 16:48:00 UTC, 0 replies.
- [PR] (WIP-PoC) KIP-1356: IQv2 TimestampedKeyWithHeadersQuery for headers-aware state stores [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/06/15 17:57:53 UTC, 4 replies.
- [PR] MINOR: Cleanups following KAFKA-20637 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/15 19:50:08 UTC, 0 replies.
- [jira] [Created] (KAFKA-20697) Add cross-version system tests - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/15 19:52:00 UTC, 0 replies.
- [PR] KAFKA-19200: Recover pre-allocated never-written time index on startup [kafka] - posted by "sidharthdaga (via GitHub)" <gi...@apache.org> on 2026/06/15 19:54:57 UTC, 3 replies.
- [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka] - posted by "suzhiking (via GitHub)" <gi...@apache.org> on 2026/06/15 21:22:10 UTC, 4 replies.
- Re: [PR] KAFKA-20116: WIP [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/15 23:49:48 UTC, 1 replies.
- [PR] Gradle 10 migration/20260615 2121 g951 to papi 20260609 [kafka] - posted by "abstratt (via GitHub)" <gi...@apache.org> on 2026/06/16 00:54:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor - posted by "Evan Zhou (Jira)" <ji...@apache.org> on 2026/06/16 02:07:00 UTC, 0 replies.
- Re: [PR] KAFKA-20088: CIDR-based Host Patterns for ACLs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 04:39:36 UTC, 15 replies.
- Re: [PR] Mm2 fault tolerance enhancement [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 05:16:25 UTC, 1 replies.
- Re: [PR] KAFKA-20270 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/16 05:16:33 UTC, 2 replies.
- Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Server Side. [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/16 07:31:11 UTC, 4 replies.
- [PR] KAFKA-20693: fix npe in abstract herder when no config value [kafka] - posted by "gaetancollaud (via GitHub)" <gi...@apache.org> on 2026/06/16 08:06:18 UTC, 1 replies.
- Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (1/N) [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/16 08:46:36 UTC, 1 replies.
- Re: [PR] KAFKA-20694: Fix share read leader epoch sentinel [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/16 09:09:59 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/06/16 09:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/06/16 09:14:00 UTC, 1 replies.
- [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/06/16 10:09:35 UTC, 1 replies.
- [jira] [Created] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context - posted by "Souquières Adam (Jira)" <ji...@apache.org> on 2026/06/16 14:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20700) AllowedPaths should resolve symlinks before validating paths against allowed.paths - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/16 14:15:00 UTC, 0 replies.
- [PR] KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context [kafka] - posted by "SouquieresAdam (via GitHub)" <gi...@apache.org> on 2026/06/16 14:15:37 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-20701) KIP drafting, publication, discussion, vote - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20701) KIP drafting, publication, discussion, vote - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/16 14:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20701) KIP drafting, publication, discussion, vote - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/16 14:59:00 UTC, 0 replies.
- [PR] MINOR: Migrate AuthorizerIntegrationTest to ClusterInstance [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/16 16:13:43 UTC, 4 replies.
- [PR] KAFKA-20693: Fix NPE in AbstractHerder config-validation error handling [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/16 17:13:22 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/06/16 17:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/16 18:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller - posted by "Haifeng Chen (Jira)" <ji...@apache.org> on 2026/06/16 18:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20522) Refine test coverage for consumer close-on-interrupt best-effort behavior - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/16 19:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/16 19:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/16 19:03:06 UTC, 1 replies.
- [PR] KAFKA-12759: Rebalance when a static member's subscription changes (classic protocol) [kafka] - posted by "danoSF (via GitHub)" <gi...@apache.org> on 2026/06/16 21:28:31 UTC, 1 replies.
- [PR] KAFKA-15701: Expose the requesting principal to CreateTopicPolicy and AlterConfigPolicy [kafka] - posted by "danoSF (via GitHub)" <gi...@apache.org> on 2026/06/16 21:30:31 UTC, 2 replies.
- [jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Preethi KCS (Jira)" <ji...@apache.org> on 2026/06/16 23:19:00 UTC, 3 replies.
- Re: [PR] WIP: KAFKA-20292: Implement offloaded assignments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:37:04 UTC, 8 replies.
- Re: [PR] KAFKA-20032: KIP-1265 Automatic detection of internal API usage [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 04:38:01 UTC, 6 replies.
- Re: [PR] KAFKA-18874: Fix KRaft controller registration retry on timeout [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:12 UTC, 1 replies.
- Re: [PR] KAFKA-19878 : Connect | Fixed order of arguments in assertEquals in connect package [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:21 UTC, 1 replies.
- Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:27 UTC, 1 replies.
- Re: [PR] KAFKA-20237: Re-enqueue InitProducerId request after authentication failure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:36 UTC, 1 replies.
- Re: [PR] KAFKA-20199: Use NodeId selector metric tag on controller-only KRaft nodes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/17 05:11:39 UTC, 1 replies.
- [jira] [Created] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers - posted by "kravii (Jira)" <ji...@apache.org> on 2026/06/17 05:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers - posted by "kravii (Jira)" <ji...@apache.org> on 2026/06/17 05:40:00 UTC, 0 replies.
- [PR] KAFKA-20116: Make task-offset-sum available to client background thread (1/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/17 06:46:13 UTC, 15 replies.
- [PR] HOTFIX: remove incorrect public API change [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/17 06:50:55 UTC, 2 replies.
- Re: [PR] KAFKA-3073: Add topic regex support for Connect sinks [kafka] - posted by "yiso-u0 (via GitHub)" <gi...@apache.org> on 2026/06/17 07:26:50 UTC, 1 replies.
- [PR] KAFKA-20491: Add uncommitted bytes limit [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/17 07:40:55 UTC, 13 replies.
- Re: [PR] MINOR: Caching immutable voterKeys [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2026/06/17 07:56:10 UTC, 1 replies.
- [PR] KAFKA-19543: fix(consumer): keep metrics available after close [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/17 08:07:05 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20049) kafka-site build depends on hvishwanath/hugo - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/06/17 08:27:00 UTC, 1 replies.
- [PR] KAFKA-19583: fix: enable oauthbearer sasl with native image [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/17 08:42:39 UTC, 1 replies.
- [PR] MINOR: Fix error message for streams group reset [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/17 09:43:08 UTC, 2 replies.
- [PR] KAFKA-20678: Support share group DLQ remote record fetch. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/17 10:09:06 UTC, 15 replies.
- Re: [PR] MINOR: Rewrite FetchFromFollowerIntegrationTest from Scala to Java and move to server module [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/06/17 11:51:31 UTC, 0 replies.
- [PR] KAFKA-20610: Minor - Renaming variables to not include replica manager reference (5/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/06/17 11:53:10 UTC, 1 replies.
- [jira] [Created] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/17 12:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/17 12:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20710) ShareCoordinatorService periodic jobs can duplicate after share feature disable/re-enable - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/17 12:24:00 UTC, 0 replies.
- [PR] KAFKA-20710: Share coordinator - Fence stale periodic jobs [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/17 12:25:29 UTC, 18 replies.
- [jira] [Assigned] (KAFKA-20583) KRaft controller does not support dynamic SSL certificate reload for CONTROLLER listener unlike broker listeners - posted by "Mahsa Seifikar (Jira)" <ji...@apache.org> on 2026/06/17 14:50:00 UTC, 0 replies.
- [PR] MINOR: Remove jqwik dependency [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/17 15:11:41 UTC, 6 replies.
- [jira] [Commented] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/17 15:56:00 UTC, 3 replies.
- [PR] KAFKA-20009: Add short descriptions to documentation sections [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/17 16:21:33 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19979) Improve Kafka Streams config files - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/17 17:02:00 UTC, 1 replies.
- [PR] MINOR: Add LICENSE and NOTICE to site-docs tar [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/17 17:58:56 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19092) Flaky test QuorumControllerTest#testBalancePartitionLeaders - posted by "Surya Kanta De (Jira)" <ji...@apache.org> on 2026/06/17 18:24:00 UTC, 1 replies.
- [PR] KAFKA-20524: Improve reset offset usability [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/17 22:21:03 UTC, 4 replies.
- [PR] KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/17 23:45:15 UTC, 8 replies.
- [PR] KAFKA-19717: fix(connect/transforms): preserve fractional digits in InsertHeader literal values [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 01:23:31 UTC, 1 replies.
- Re: [PR] KAFKA-19280: Fix NoSuchElementException in UnifiedLog [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 01:23:34 UTC, 0 replies.
- Re: [PR] MINOR: adding AGENTS.md [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/06/18 03:53:23 UTC, 1 replies.
- [PR] KAFKA-19794: fix(mirror): avoid rewinding active consumer offsets in MirrorCheckpointTask [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 04:25:32 UTC, 1 replies.
- Re: [PR] HOTFIX: Fix build issue due to alter offsets. [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 04:25:34 UTC, 0 replies.
- Re: [PR] KAFKA-20033: make the __remote_log_metadata topic compact [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 04:36:44 UTC, 0 replies.
- Re: [PR] KAFKA-20462: Preserve original source-record headers in ErrorHandlerContext [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 04:37:12 UTC, 0 replies.
- Re: [PR] MINOR: Update Protocol Buffers documentation URLs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 05:06:53 UTC, 1 replies.
- Re: [PR] KAFKA-19968: Fix tiered storage quota enforcement issues [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 05:06:57 UTC, 1 replies.
- Re: [PR] KAFKA-19982 : Raft package assertEquals argument adjustments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 05:07:00 UTC, 1 replies.
- Re: [PR] KAFKA-19331: Fix misleading log messages when follower's leader is not in metadata image [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/18 05:07:03 UTC, 1 replies.
- [PR] MINOR: Fix typo in KafkaConsumerTest method name [kafka] - posted by "david-parkk (via GitHub)" <gi...@apache.org> on 2026/06/18 05:09:36 UTC, 1 replies.
- [PR] Add partition support to TestRecord [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/06/18 08:53:32 UTC, 14 replies.
- [jira] [Comment Edited] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/18 09:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20711) Streams task restore-remaining-records metric invalid under EOS - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/06/18 09:12:00 UTC, 0 replies.
- [PR] MINOR: Fix assertion and grammar issues in KafkaConsumerTest [kafka] - posted by "david-parkk (via GitHub)" <gi...@apache.org> on 2026/06/18 09:29:19 UTC, 1 replies.
- [PR] KAFKA-20711: Measure restore progress in offset slots [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/18 10:03:54 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20711) Streams task restore-remaining-records metric invalid under EOS - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/06/18 10:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/06/18 10:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/06/18 10:08:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20541) Duplicate generated folder in kafka-site - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/18 10:48:00 UTC, 0 replies.
- [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/06/18 10:48:34 UTC, 9 replies.
- [PR] KAFKA-20623: Follow-up cleanups for the streams group topology description plugin [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/18 10:51:37 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20009) Top level pages should include short descriptions for each section - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/18 10:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20711) Streams task restore-remaining-records metric never reaches 0 - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/06/18 12:02:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19404) Connect's plugin.path documentation does not match behavior - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/18 12:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-20599: Improve retry logic in KafkaStatusBackingStore with exponential backoff [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/18 13:09:32 UTC, 1 replies.
- [jira] [Created] (KAFKA-20713) Review level for client-side log on fetch session evicted - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/18 14:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20713) Review level for client-side log on fetch session evicted - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/18 14:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/18 15:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20627) Add broker integration tests for topology description plugin - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/18 15:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20630) Add documentation for topology description plugin feature - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/18 15:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20629) Add ducktape system tests for topology description plugin - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/18 15:02:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20697) Add cross-version system tests - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/06/18 15:10:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-20697) Add cross-version system tests - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/06/18 15:12:00 UTC, 0 replies.
- [PR] KAFKA-20713: Lower level for client log on self-healing session not found [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/18 16:46:16 UTC, 4 replies.
- [jira] [Created] (KAFKA-20714) Refactor KRaft API around message handling - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/18 17:55:00 UTC, 0 replies.
- [PR] KAFKA-19867: fix(raft): avoid UpdateVoteRequest from broker-only nodes [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 18:00:43 UTC, 1 replies.
- Re: [PR] MINOR: Refactor createResponseConfig to avoid collection copy and conversion [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 18:00:45 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16213) KRaft should honor voterId outside of VotedState - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/18 18:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/06/18 19:11:00 UTC, 1 replies.
- [PR] KAFKA-19880: fix(storage): reject non-zero sequence on first batch with no producer state [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 19:47:52 UTC, 1 replies.
- Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.1.3 [kafka] - posted by "wilmerdooley (via GitHub)" <gi...@apache.org> on 2026/06/18 19:47:54 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19738) Improve testing of OffsetsRequestManager to better match OffsetFetcher - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/06/18 20:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-16213; Refactor KRaft API around message handling [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/06/18 20:25:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16213) KRaft should honor voterId outside of VotedState - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/18 20:27:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20714) Refactor KRaft API around message handling - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/18 20:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id - posted by "Preethi KCS (Jira)" <ji...@apache.org> on 2026/06/18 21:08:00 UTC, 2 replies.
- [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/06/18 21:38:52 UTC, 16 replies.
- [jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/18 21:59:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/18 22:00:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/18 22:03:00 UTC, 1 replies.
- [PR] KAFKA-19092: Fix flaky testBalancePartitionLeaders by reducing check interval and increasing timeout [kafka] - posted by "suryakantade (via GitHub)" <gi...@apache.org> on 2026/06/19 06:04:48 UTC, 1 replies.
- Re: [PR] KAFKA-19042 Move AuthorizerIntegrationTest to client-integration-tests module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/19 08:24:28 UTC, 1 replies.
- [PR] KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/19 10:14:24 UTC, 13 replies.
- [jira] [Updated] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/06/19 10:22:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20715) Cluster Mirroring - Synchronous mode - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2026/06/19 11:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20716) LSO stuck after unclean leader election - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/19 11:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20716) LSO stuck after unclean leader election - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/19 11:34:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20716) LSO stuck after unclean leader election - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/19 11:36:00 UTC, 1 replies.
- Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/19 13:22:56 UTC, 4 replies.
- [jira] [Created] (KAFKA-20717) Add KIP-1331 broker-side observability sensors (plugin.setTopology / plugin.getTopology) - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/06/19 13:24:00 UTC, 0 replies.
- [PR] MINOR: Improve handling adding metadata versions [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/06/19 13:40:47 UTC, 1 replies.
- [PR] MINOR: Bump Setup Gradle to 6.2.0 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/19 14:05:42 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/19 14:08:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20491) Enforce transaction buffer memory limitstatestore.uncommitted.max.bytes - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/19 15:06:00 UTC, 0 replies.
- [PR] KAFKA-20493: Transactional RocksDBStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/19 15:09:31 UTC, 14 replies.
- [PR] KAFKA-20494: Transactional InMemoryKeyValueStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/19 15:09:44 UTC, 9 replies.
- [PR] KAFKA-20624: Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/19 16:15:56 UTC, 4 replies.
- [PR] MINOR: Test Producer's and Accumulator's Behavior When Batch Size is Zero [kafka] - posted by "jack2012aa (via GitHub)" <gi...@apache.org> on 2026/06/19 17:20:57 UTC, 1 replies.
- Re: [PR] KAFKA-19871 - Add partition support to TestRecord [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/06/19 19:10:07 UTC, 23 replies.
- [PR] MINOR: add missing log enabled check [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/19 19:33:00 UTC, 1 replies.
- Re: [PR] KAFKA-20664: Clarify docs on max compaction lag, segment.ms, and segment.bytes for active segment rolling [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/19 23:21:27 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20664) Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/19 23:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/19 23:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/19 23:24:00 UTC, 0 replies.
- Re: [PR] MINOR: Followup Add KIP-1284 into streams upgrade document [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/20 04:34:07 UTC, 0 replies.
- [jira] [Created] (KAFKA-20718) Flaky: OffsetStorageReaderTest -> testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/20 08:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20718) Flaky: OffsetStorageReaderTest -> testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/20 08:55:00 UTC, 1 replies.
- [jira] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer - posted by "Deepa Maria Polson (Jira)" <ji...@apache.org> on 2026/06/20 12:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/20 18:56:00 UTC, 0 replies.
- [PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/20 19:08:53 UTC, 8 replies.
- [jira] [Commented] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/20 19:10:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/20 19:29:00 UTC, 0 replies.
- [PR] KAFKA-20700: Resolve symlinks in AllowedPaths before validation [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/20 21:30:43 UTC, 2 replies.
- [jira] [Created] (KAFKA-20720) Review level for client-side log on share session errors - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/20 22:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20720) Review level for client-side log on share session errors - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/20 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20720) Review level for client-side log on share session errors - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/20 22:32:00 UTC, 1 replies.
- Re: [PR] KAFKA: Clarify allow.everyone.if.no.acl.found documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/21 05:13:18 UTC, 1 replies.
- [PR] KAFKA-20718: Fix flaky test OffsetStorageReaderTest.testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/21 15:08:56 UTC, 1 replies.
- Re: [PR] KAFKA-17871: avoid blocking the herder thread when producer flushing hangs [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/21 15:41:49 UTC, 0 replies.
- [PR] MINOR: optimize cooperative assignment validation [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/06/21 15:47:16 UTC, 1 replies.
- [jira] [Created] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug." - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/21 17:03:00 UTC, 0 replies.
- [PR] KAFKA-20695: Extend "describe group" to return "task offset" metadata [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/06/21 19:58:37 UTC, 8 replies.
- [jira] [Created] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/06/21 20:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933 - posted by "Aleksei Veremeev (Jira)" <ji...@apache.org> on 2026/06/21 20:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug." - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 08:04:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20723) Harden ShareGroupDLQStateManager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/22 08:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20723) Harden ShareGroupDLQStateManager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/22 08:29:00 UTC, 0 replies.
- [PR] KAFKA-20723: Add fail fast check for share group dlq(...). [1/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/22 08:45:59 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug." - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 09:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20724) Topology pausing may have race condition - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 09:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20724) Topology pausing may have race condition - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 09:18:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20725) Provide in-rack traffic observability for clients and brokers - posted by "Ivan Yurchenko (Jira)" <ji...@apache.org> on 2026/06/22 11:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20725) Provide in-rack traffic observability for clients and brokers - posted by "Ivan Yurchenko (Jira)" <ji...@apache.org> on 2026/06/22 11:08:00 UTC, 0 replies.
- [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/22 11:11:27 UTC, 6 replies.
- [jira] [Updated] (KAFKA-20627) Add broker integration tests for topology description plugin - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 11:55:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-20629) Add ducktape system tests for topology description plugin - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 11:56:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20335) Update docs - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2026/06/22 12:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20336) Update docs - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2026/06/22 12:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20569) Doc doesn't have upgrading steps - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2026/06/22 12:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." caused by a duplicate TaskId from DefaultStateUpdater.tasks() under pause/resume - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 12:27:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/22 12:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." caused by a duplicate TaskId from DefaultStateUpdater.tasks() under pause/resume - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 12:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-17946) Flaky test DeafultStateUpdaterTest::shouldResumeStandbyTask due to concurrency issue - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 12:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-17946) Flaky test DeafultStateUpdaterTest::shouldResumeStandbyTask due to concurrency issue - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 12:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." caused by a duplicate TaskId from DefaultStateUpdater.tasks() under pause/resume - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 12:38:00 UTC, 3 replies.
- [jira] [Reopened] (KAFKA-18771) Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/22 13:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18771) Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/06/22 13:09:00 UTC, 0 replies.
- [PR] MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/06/22 14:50:39 UTC, 3 replies.
- [PR] MINOR: move DelayedProduceTest to server module [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/06/22 15:26:14 UTC, 1 replies.
- Re: [PR] KAFKA-20618: KIP-1331 Streams Group Topology Description Plugin (POC) [kafka] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/06/22 15:44:21 UTC, 0 replies.
- [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/06/22 15:54:30 UTC, 0 replies.
- [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 (KAFKA-20456 family, no pause/resume) - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 16:09:00 UTC, 0 replies.
- [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 (KAFKA-20456 family, no pause/resume) - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 16:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19638) NPE in `Processor#init()` accessing state store - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/22 16:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/22 16:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20724) Topology pausing may have race condition - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/22 16:15:00 UTC, 4 replies.
- [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/06/22 17:14:37 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/22 17:29:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/22 17:36:00 UTC, 0 replies.
- [PR] MINOR: reduce allocations construction RecordHeaders [kafka] - posted by "winfriedgerlach (via GitHub)" <gi...@apache.org> on 2026/06/22 19:42:13 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20494) Transactional support for InMemoryKeyValueStore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/22 20:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20726) Don't reuse the BufferSupplier in kraft state machine - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/22 20:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20726) Don't reuse the BufferSupplier in kraft state machine - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/22 20:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20727) Update Kafka Streams system tests for transactional stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/22 20:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154) - posted by "Netan Mangal (Jira)" <ji...@apache.org> on 2026/06/22 21:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20727) Update Kafka Streams system tests for transactional stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/22 21:57:00 UTC, 1 replies.
- [PR] KAFKA-20727: Update system tests for transactional state stores [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/22 22:20:30 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20493) Transactional support for RocksDBStore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/22 22:54:00 UTC, 0 replies.
- Re: [PR] KAFKA-20116: Send task-(end)-offset to broker (3/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/23 00:01:09 UTC, 11 replies.
- [jira] [Assigned] (KAFKA-20729) RocksDBTransactionBuffer missing newBaseSnapshotIterator breaks trunk compile - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/23 01:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20729) RocksDBTransactionBuffer missing newBaseSnapshotIterator breaks trunk compile - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/23 01:31:00 UTC, 0 replies.
- [PR] KAFKA-20729: Implement newBaseSnapshotIterator in RocksDBTransactionB… [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/23 01:41:23 UTC, 10 replies.
- [jira] [Created] (KAFKA-20730) Remove spotless from streams-scala - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/23 04:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20730) Remove spotless from streams-scala - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/23 04:06:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20730) Remove spotless from streams-scala - posted by "Jiayao Sun (Jira)" <ji...@apache.org> on 2026/06/23 04:15:00 UTC, 0 replies.
- [PR] KAFKA-20116: Forwad task-(end)-offset-sum to task assignor (4/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/23 04:38:53 UTC, 0 replies.
- Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 04:50:02 UTC, 1 replies.
- Re: [PR] KAFKA-19735: Add automatic commit offset caching in subscribe mode [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 04:50:04 UTC, 1 replies.
- Re: [PR] KAFKA-18608: feat: implement private_key_jwt client authentication for OAuth 2.0 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 04:50:09 UTC, 1 replies.
- Re: [PR] KAFKA-20253: Fix high CPU spin loop after failed SASL re-authentication [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/23 04:50:15 UTC, 1 replies.
- [PR] KAFKA-20116: Send task-(end)-offset only if changed (5/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/23 05:30:52 UTC, 4 replies.
- [PR] HOTFIX: fix compilation error [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/23 05:39:52 UTC, 1 replies.
- Re: [PR] MINOR: reduce allocations constructing RecordHeaders [kafka] - posted by "winfriedgerlach (via GitHub)" <gi...@apache.org> on 2026/06/23 06:13:50 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20662) Proper error code for malformed request during online migration - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/23 07:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] [kafka] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/06/23 07:07:37 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-20601) ConsumerGroup static member rejoin can fail with GroupMaxSizeReachedException at max size - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/23 07:10:00 UTC, 0 replies.
- [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 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/23 09:09:00 UTC, 0 replies.
- [PR] KAFKA-20686: Add base integ tests for share group DLQ. [1/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/23 09:13:33 UTC, 2 replies.
- [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 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/23 09:20:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20729) RocksDBTransactionBuffer missing newBaseSnapshotIterator breaks trunk compile - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/23 11:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/23 11:34:00 UTC, 0 replies.
- [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 - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/23 11:36:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/23 11:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20608) classic consumer static member rejoin can fail with GroupMaxSizeReachedException at max size - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/23 11:46:00 UTC, 0 replies.
- [PR] KAFKA-20490: Replace txn buffer skip-list with TreeMap [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/23 12:36:10 UTC, 5 replies.
- Re: [PR] MINOR: Move DelayedProduceTest to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/23 12:45:55 UTC, 3 replies.
- [jira] [Created] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1) - posted by "Adam Horky (Jira)" <ji...@apache.org> on 2026/06/23 12:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1) - posted by "Adam Horky (Jira)" <ji...@apache.org> on 2026/06/23 12:58:00 UTC, 1 replies.
- [PR] KAFKA-20724: prevent duplicate task in tasks() during pause and resume [kafka] - posted by "zoro30102000 (via GitHub)" <gi...@apache.org> on 2026/06/23 13:10:32 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20724) Topology pausing may have race condition - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/23 13:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20524) Initialization of share group offsets from a specific offset or a file - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/06/23 13:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread - posted by "Eswarar Siva (Jira)" <ji...@apache.org> on 2026/06/23 13:30:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol - posted by "Jiwon Park (Jira)" <ji...@apache.org> on 2026/06/23 15:07:00 UTC, 0 replies.
- [PR] MINOR: Merge kafka.security classes into test-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/23 15:55:58 UTC, 0 replies.
- Re: [PR] KAFKA-20259: Verify IQv1 and IQv2 do not break with headers-aware state stores [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/23 16:02:40 UTC, 0 replies.
- [PR] KAFKA-20733: Fix fetchResponseWithUnexpectedPartitionIsIgnored passing for wrong reason with CONSUMER protocol [kafka] - posted by "david-parkk (via GitHub)" <gi...@apache.org> on 2026/06/23 16:04:40 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/23 16:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20730) Remove spotless from streams-scala - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/23 16:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17164) Consider to enforce application.server : format at config level - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/23 17:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-17164) Consider to enforce application.server : format at config level - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/23 17:23:00 UTC, 0 replies.
- [PR] KAFKA-20495: Add transactional support to in-memory window and session stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/23 18:23:57 UTC, 9 replies.
- [PR] KAFKA-20498: Add isolation-level reads to RocksDBStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/23 18:32:10 UTC, 4 replies.
- [PR] KAFKA-20579: Initial producer incremental allocation for uncompressed data [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/23 18:34:17 UTC, 0 replies.
- [PR] Sync 2 recent commits to 4.2 [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/23 20:07:57 UTC, 1 replies.
- [PR] Sync 2 recent commits to 4.3 [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/23 20:09:41 UTC, 1 replies.
- [PR] MINOR: Update docker_scan supported_image_tag for 4.3.1 [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/23 23:38:20 UTC, 1 replies.
- [jira] [Created] (KAFKA-20734) Offline partition can cause loss of transaction markers - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2026/06/24 00:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20734) Offline partition can cause loss of transaction markers - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2026/06/24 00:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20734) Offline partition can cause loss of transaction markers - posted by "Artem Livshits (Jira)" <ji...@apache.org> on 2026/06/24 00:29:00 UTC, 1 replies.
- Re: [PR] DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/24 04:53:05 UTC, 1 replies.
- Re: [PR] KAFKA-20349: Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/24 04:53:21 UTC, 0 replies.
- Re: [PR] KAFKA-20116: Forwad task-(end)-offset to task assignor (4/N) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/06/24 07:39:17 UTC, 1 replies.
- [PR] KAFKA-60665: Add refiner scaffolding for "streams" warmup tasks [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/24 07:55:32 UTC, 0 replies.
- [PR] KAFKA-19354 on 3.9 [kafka] - posted by "giuseppelillo (via GitHub)" <gi...@apache.org> on 2026/06/24 08:08:27 UTC, 1 replies.
- [PR] MINOR: Code cleanups in coordinator-common runtime [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/06/24 08:13:53 UTC, 2 replies.
- [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka] - posted by "horkyada (via GitHub)" <gi...@apache.org> on 2026/06/24 08:48:24 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20732) Data loss: tiered size-retention deletes in-retention data from both tiers after leader election when highestOffsetInRemoteStorage is unset (-1) - posted by "Adam Horky (Jira)" <ji...@apache.org> on 2026/06/24 08:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/24 08:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20717) Add KIP-1331 broker-side observability sensors (plugin.setTopology / plugin.getTopology) - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/24 10:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18998) Move AuthHelper to server module - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/06/24 10:15:00 UTC, 0 replies.
- [PR] KAFKA-20723: Merge records while coalescing share DLQ requests. [2/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/24 11:22:13 UTC, 6 replies.
- Re: [PR] KAFKA-18775: Simplify controller quorum changes through the Admin API [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/06/24 12:10:56 UTC, 33 replies.
- [jira] [Created] (KAFKA-20735) Streams logs ERROR "Failed to acquire lock while closing the state store" for lock contention during back-to-back rebalances - posted by "Artur Dudko (Jira)" <ji...@apache.org> on 2026/06/24 13:51:00 UTC, 0 replies.
- [PR] KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserialization in group coordinator [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/24 13:52:20 UTC, 1 replies.
- [PR] KAFKA-20717: Add broker-side set/get observability sensors for streams topology description (KIP-1331) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/24 14:13:33 UTC, 5 replies.
- Re: [PR] KAFKA-14228 Support for nested structures: ValueToKey [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/24 14:40:57 UTC, 2 replies.
- [PR] KFK-19871: A, Add Builder and Runtime for Multipartition for TopologyTestDriver [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/06/24 16:12:15 UTC, 0 replies.
- [jira] [Created] (KAFKA-20736) Improve leadership change handling in ShareConsumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/06/24 16:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20659) MirrorMaker Checkpoint and Heartbeat records can accept unsupported versions when assertions are disabled - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/24 18:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20659) MirrorMaker Checkpoint and Heartbeat records can accept unsupported versions when assertions are disabled - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/24 18:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20700) AllowedPaths should resolve symlinks before validating paths against allowed.paths - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/24 18:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-20377: Forward --build-arg flags through ducker-ak [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/24 18:42:18 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20377) ducker-ak does not support passing additional Docker build arguments - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/24 18:43:00 UTC, 0 replies.
- Re: [PR] MINOR: Rewrite AuthorizerIntegrationTest and rename to ConsumerGroupCommandAuthorizationTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/24 19:44:37 UTC, 2 replies.
- Re: [PR] MINOR: Move LoggingController log level resolution test to server [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/24 20:01:17 UTC, 0 replies.
- [PR] KAFKA-20703: IQv2 TimestampedKeyWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/06/24 20:21:09 UTC, 11 replies.
- [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka] - posted by "peterzdhuang (via GitHub)" <gi...@apache.org> on 2026/06/24 20:31:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/24 21:10:00 UTC, 0 replies.
- [PR] KAFKA-20730: Remove scalafmt from streams-scala Spotless config [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/06/24 21:56:04 UTC, 1 replies.
- [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] - posted by "anjy7 (via GitHub)" <gi...@apache.org> on 2026/06/25 01:16:52 UTC, 55 replies.
- [jira] [Commented] (KAFKA-20735) Streams logs ERROR "Failed to acquire lock while closing the state store" for lock contention during back-to-back rebalances - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/06/25 03:04:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer - posted by "Sakshi Yadav (Jira)" <ji...@apache.org> on 2026/06/25 04:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6889) Fix Streams system test to only specify used log files - posted by "Sakshi Yadav (Jira)" <ji...@apache.org> on 2026/06/25 04:31:00 UTC, 0 replies.
- Re: [PR] KAFKA-19408 : Add check for compression type mismatch for push telemetry requests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:52:48 UTC, 1 replies.
- Re: [PR] KAFKA-16799: Reduce log level for 'Node is not ready' message to TRACE [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:52:54 UTC, 1 replies.
- Re: [PR] KAFKA-8958 : Fix Kafka Streams JavaDocs with regard to used Serdes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:52:58 UTC, 1 replies.
- Re: [PR] KAFKA-20097: Populate topicId for existing topics in CreateTopics response [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:53:01 UTC, 1 replies.
- Re: [PR] MM2: Add offset gap detection and basic topic reset handling in MirrorSourceTask [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/25 04:53:06 UTC, 1 replies.
- [jira] [Created] (KAFKA-20737) add CI to check the link of archived releases - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/25 05:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20737) add CI to check the link of archived releases - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/06/25 06:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20737) add CI to check the link of archived releases - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/06/25 06:48:00 UTC, 0 replies.
- [PR] MINOR: Add logging for topology description push in streams group protocol [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/25 08:50:58 UTC, 2 replies.
- Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/06/25 09:48:49 UTC, 16 replies.
- Re: [PR] KAFKA-20619: ClusterTestExtensions skip jdk.internal.ref.CleanerImpl … [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/25 10:17:36 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/06/25 10:18:00 UTC, 0 replies.
- [PR] KAFKA-20686: Expand system test suite for share group DLQ. [2/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/25 10:31:18 UTC, 0 replies.
- Re: [PR] Enhanced mm2 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/25 10:50:38 UTC, 1 replies.
- [PR] KAFKA-18998: Clean up AuthHelper following review feedback [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/25 13:36:06 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20645) Move LogLoaderTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/25 13:49:00 UTC, 0 replies.
- [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/06/25 13:55:46 UTC, 29 replies.
- [jira] [Created] (KAFKA-20738) Producer 2PC init sets v6-only InitProducerId fields but request builder caps version at v5 - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/25 14:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/25 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/06/25 14:43:00 UTC, 0 replies.
- [PR] KAFKA-20553: Remove Scala dependency from streams:integration-tests [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/25 14:54:30 UTC, 1 replies.
- [PR] MINOR: Follow-up KAFKA-20696 [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/06/25 15:17:28 UTC, 11 replies.
- [jira] [Created] (KAFKA-20740) It is possible to have more hand one concurrent voter change operation - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/25 15:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/25 15:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20741) Add ReadOnlyRecord Interface - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/25 15:58:00 UTC, 0 replies.
- [PR] KAFKA-20741: Add ReadOnlyRecord IQv2 result type (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/06/25 16:02:33 UTC, 11 replies.
- [jira] [Updated] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/25 16:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20706) Implement query type 4 (TimestampedWindowRangeQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/25 16:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20740) It is possible to have more hand one concurrent voter change operation - posted by "Jonah Hooper (Jira)" <ji...@apache.org> on 2026/06/25 16:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16517) Do not decode metadata records in the internal kraft partition listener - posted by "tony tang (Jira)" <ji...@apache.org> on 2026/06/25 17:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20740) It is possible to have more than one concurrent voter change operation - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/06/25 17:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20498) RocksDBStore readOnly implementation - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/25 18:08:00 UTC, 0 replies.
- [PR] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "0xffff-zhiyan (via GitHub)" <gi...@apache.org> on 2026/06/25 19:30:56 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20495) Transactional support for InMemorySessionStore and InMemoryWindowStore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/25 21:09:00 UTC, 0 replies.
- [PR] MINOR: Fix ShareGroupCommandTest reset-offsets tests passing invalid --from-file scope combination [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/06/26 03:27:28 UTC, 1 replies.
- Re: [PR] KAFKA-20116: Send task-(end)-offset only if changed (4/N) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/26 04:08:54 UTC, 0 replies.
- Re: [PR] MINOR: Rewrite SaslClientsWithInvalidCredentialsTest and rename to ConsumerGroupCommandSaslAuthenticationTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/26 04:33:52 UTC, 0 replies.
- [PR] KAFKA-20734: Return noNode for known partitions without endpoints [kafka] - posted by "xiaoqingwanga (via GitHub)" <gi...@apache.org> on 2026/06/26 06:37:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20734) Offline partition can cause loss of transaction markers - posted by "Wang Xiaoqing (Jira)" <ji...@apache.org> on 2026/06/26 06:38:00 UTC, 0 replies.
- [PR] KAFKA-20499: Add isolation-level reads to in-memory stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/26 08:27:12 UTC, 7 replies.
- [PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/26 08:27:44 UTC, 5 replies.
- [PR] KAFKA-20490: Track committed and uncommitted RocksDB Positions [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/26 08:28:04 UTC, 9 replies.
- [jira] [Created] (KAFKA-20742) Start offset for newly initialized share partitions should be 0 - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/26 10:36:00 UTC, 0 replies.
- [PR] KAFKA-19491 CONSUMER protocol metrics documentation [kafka] - posted by "Ritikj55 (via GitHub)" <gi...@apache.org> on 2026/06/26 10:47:35 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics - posted by "RITIK KUMAR JAISWAL (Jira)" <ji...@apache.org> on 2026/06/26 10:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator. - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/26 11:19:00 UTC, 0 replies.
- [PR] KAFKA-20743: Restrict sentinel leader and state epoch in share coord. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/26 11:27:42 UTC, 1 replies.
- Re: [PR] KAFKA-20665: Add refiner scaffolding for "streams" warmup tasks [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/26 11:46:16 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-20727) Update Kafka Streams system tests for transactional stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/26 13:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20701) KIP drafting, publication, discussion, vote - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/06/26 13:22:00 UTC, 0 replies.
- [PR] KAFKA-18707: Move KRaftMetadataCachePublisher to metadata module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/06/26 14:06:22 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/26 14:32:00 UTC, 0 replies.
- [PR] MINOR: Add 4.3.1 to system tests [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/26 15:22:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator. - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/06/26 15:42:00 UTC, 0 replies.
- Re: [PR] KAFKA-20686: Expand integration test suite for share group DLQ. [2/N] [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/06/26 16:10:12 UTC, 0 replies.
- [PR] Added support for dynamic SSL certificate reload for controllers [kafka] - posted by "aschmidt402 (via GitHub)" <gi...@apache.org> on 2026/06/26 16:18:14 UTC, 0 replies.
- [PR] KAFKA-20297: Deprecate Time-accepting constructors in KafkaStreams and Metrics [kafka] - posted by "siddharthaDevineni (via GitHub)" <gi...@apache.org> on 2026/06/26 17:45:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-20744) Add back `rack.aware.assignment.tags` config - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/06/26 19:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20744) Add back `rack.aware.assignment.tags` config - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/06/26 19:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20116) Support HA assignor in the streams rebalance protocol - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/26 20:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/26 23:09:00 UTC, 3 replies.
- Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 04:47:39 UTC, 1 replies.
- Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/27 04:47:45 UTC, 0 replies.
- [PR] docs: update 'Testing a Streams Application' example code [kafka] - posted by "agebhar1 (via GitHub)" <gi...@apache.org> on 2026/06/27 08:47:40 UTC, 1 replies.
- [PR] KAFKA-20720: Lower level for client log on self-healing share session… [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/06/27 19:41:33 UTC, 5 replies.
- [PR] KAFKA-20292 [4/N]: Lift member updates out of streams TargetAssignmentBuilder [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/27 23:29:24 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-12227) Add method "Producer#send" to return CompletionStage instead of Future - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/06/28 02:53:00 UTC, 0 replies.
- [PR] ci: pin GitHub Actions to full commit SHAs [kafka] - posted by "XananasX7 (via GitHub)" <gi...@apache.org> on 2026/06/28 04:18:13 UTC, 1 replies.
- Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 05:01:35 UTC, 0 replies.
- Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/28 05:01:42 UTC, 1 replies.
- [PR] MINOR: Add EdgeML-Broker scaffold for edge AI [kafka] - posted by "sakshampaswanofficial (via GitHub)" <gi...@apache.org> on 2026/06/28 08:12:59 UTC, 2 replies.
- Re: [PR] MINOR: Move BrokerReconfigurable to server module [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/06/28 11:46:48 UTC, 2 replies.
- [jira] [Created] (KAFKA-20745) add tests for OffsetMapTest to verify different hash algorithms? - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/28 17:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20745) add tests for OffsetMapTest to verify different hash algorithms? - posted by "Jimmy Wang (Jira)" <ji...@apache.org> on 2026/06/28 17:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 05:05:21 UTC, 2 replies.
- Re: [PR] WIP: Removing WindowedSerializer interface from public class implementations [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/06/29 05:05:25 UTC, 0 replies.
- [PR] MINOR: Fix typos in documentation [kafka] - posted by "Joanna-D (via GitHub)" <gi...@apache.org> on 2026/06/29 06:36:20 UTC, 1 replies.
- [jira] [Created] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/06/29 06:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2026/06/29 06:57:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2026/06/29 06:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20742) Start offset for newly initialized share partitions should be 0 - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/06/29 07:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/29 10:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/06/29 10:52:00 UTC, 0 replies.
- Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/06/29 10:58:13 UTC, 0 replies.
- [PR] MINOR: Document top-level-only field casting limitation in Cast SMT [kafka] - posted by "itsmehotpants (via GitHub)" <gi...@apache.org> on 2026/06/29 11:45:25 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20730) Remove spotless from streams-scala - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/29 11:52:00 UTC, 0 replies.
- [PR] MINOR: Add static member replacement test with new subscription and not assignment [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/29 12:01:50 UTC, 1 replies.
- [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/06/29 12:23:54 UTC, 6 replies.
- [PR] MINOR: Clarify SerializationException Javadoc [kafka] - posted by "acktsap (via GitHub)" <gi...@apache.org> on 2026/06/29 12:29:33 UTC, 1 replies.
- [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/06/29 14:14:48 UTC, 2 replies.
- [PR] KAFKA-20686: Reduce share heartbeat timeout in DLQ integ tests. [3/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/29 14:48:19 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/29 16:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/29 16:17:00 UTC, 0 replies.
- [PR] KAFKA-20738: Producer 2PC InitProducerId request must negotiate v6 [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/29 17:32:19 UTC, 2 replies.
- [PR] KAFKA-20739: Transaction coordinator accepts InitProducerId v6 keepPreparedTxn recovery [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/06/29 18:11:17 UTC, 1 replies.
- Re: [PR] KAFKA-20116: Forwad task-(end)-offset to task assignor (5/5) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/06/29 20:54:09 UTC, 0 replies.
- [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/06/29 20:55:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20697) Add cross-version system tests - posted by "Gavin Wang (Jira)" <ji...@apache.org> on 2026/06/29 21:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20678) Analyze and impl fetch from remote storage for DLQ - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/06/29 21:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V - posted by "Michael Mitchell (Jira)" <ji...@apache.org> on 2026/06/30 03:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20500) Transactional support for VersionedStores - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/06/30 08:11:00 UTC, 0 replies.
- [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/06/30 08:32:53 UTC, 0 replies.
- [jira] [Created] (KAFKA-20747) Static member rejoining with same member id and different instance id not tracked correctly - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/06/30 08:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/30 10:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/30 10:09:00 UTC, 0 replies.
- [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/30 10:14:54 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/06/30 10:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/30 13:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/30 13:26:00 UTC, 1 replies.
- [PR] KAFKA-20749: Fix for stream/stream joins and position bug [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/06/30 13:43:38 UTC, 2 replies.
- [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/06/30 14:29:08 UTC, 4 replies.
- Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/06/30 14:39:28 UTC, 1 replies.
- [PR] KAFKA-20655: Mark KIP-1331 RPCs stable before release [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/06/30 16:02:13 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20750) Divide-by-zero error in PollIdleRatio metric during sub-millisecond poll intervals. - posted by "Shivsundar R (Jira)" <ji...@apache.org> on 2026/06/30 16:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20750) Divide-by-zero error in PollIdleRatio metric during sub-millisecond poll intervals. - posted by "Shivsundar R (Jira)" <ji...@apache.org> on 2026/06/30 16:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20747) Static member rejoining with same member id and different instance id not tracked correctly - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/06/30 16:38:00 UTC, 1 replies.
- Re: [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/06/30 16:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/30 16:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation - posted by "majialong (Jira)" <ji...@apache.org> on 2026/06/30 16:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/06/30 16:56:00 UTC, 0 replies.
- [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/06/30 17:49:40 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20720) Review level for client-side log on share session errors - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/30 18:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20720) Review level for client-side log on share session errors - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/06/30 18:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/30 19:23:00 UTC, 0 replies.
- [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/06/30 19:27:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics - posted by "Dan O'Reilly (Jira)" <ji...@apache.org> on 2026/06/30 22:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20499) InMemoryStores readOnly implementations - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/06/30 22:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics - posted by "Dan O'Reilly (Jira)" <ji...@apache.org> on 2026/06/30 23:24:00 UTC, 1 replies.