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

---

- [jira] [Created] (KAFKA-20753) Transactional RocksDB store fails to reopen (TaskCorrupted loop) when a task's active and standby are transiently co-located on one instance under EOS - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 01:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2026/07/01 02:32:58 UTC, 12 replies.
- Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/01 03:01:08 UTC, 1 replies.
- Re: [PR] KAFKA-20668: Add --checkpoint option to kafka-metadata-shell [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/01 04:37:44 UTC, 2 replies.
- Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/01 04:37:47 UTC, 0 replies.
- Re: [PR] WIP: Removing WindowedSerializer interface from public class implementations [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/01 04:38:16 UTC, 0 replies.
- Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/01 05:02:42 UTC, 0 replies.
- Re: [PR] Support keystore with multiple alias entries [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/01 05:02:43 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/01 05:12:00 UTC, 0 replies.
- [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/01 06:21:37 UTC, 6 replies.
- [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/01 06:39:12 UTC, 3 replies.
- Re: [PR] KAFKA-20693: fix npe in abstract herder when no config value [kafka] - posted by "gaetancollaud (via GitHub)" <gi...@apache.org> on 2026/07/01 06:56:23 UTC, 19 replies.
- Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/01 07:13:32 UTC, 5 replies.
- Re: [PR] KAFKA-20712: Fix transaction state name in log decoder output [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/01 08:19:40 UTC, 3 replies.
- Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/01 08:34:36 UTC, 3 replies.
- Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (3/N) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/07/01 08:40:42 UTC, 6 replies.
- Re: [PR] KAFKA-20088: CIDR-based Host Patterns for ACLs [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/07/01 09:01:11 UTC, 8 replies.
- [PR] KAFKA-20753: Fix transactional status marker writes [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/01 09:04:27 UTC, 3 replies.
- [PR] KAFKA-10025: guard RocksDBMetricsRecorder value provider reads against store close [kafka] - posted by "Aangbaeck (via GitHub)" <gi...@apache.org> on 2026/07/01 09:19:53 UTC, 2 replies.
- Re: [PR] MINOR: Rewrite ClientOAuthIntegrationTest from Scala to Java [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/01 09:58:16 UTC, 1 replies.
- [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka] - posted by "ShivsundarR (via GitHub)" <gi...@apache.org> on 2026/07/01 10:14:30 UTC, 3 replies.
- Re: [PR] KAFKA-20385 [2/N]: Add setRebalanceListener into *Consumer [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/01 10:23:14 UTC, 19 replies.
- [PR] KAFKA-10397: do not expose statistics-based RocksDB metrics when the user provides a Statistics object [kafka] - posted by "Aangbaeck (via GitHub)" <gi...@apache.org> on 2026/07/01 11:09:30 UTC, 1 replies.
- [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/01 12:19:02 UTC, 3 replies.
- Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/07/01 13:37:09 UTC, 2 replies.
- Re: [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/07/01 14:09:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-20754) Disallow static member instance id changes - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/07/01 14:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20754) Disallow static member instance id changes - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/07/01 14:39:00 UTC, 0 replies.
- [PR] KAFKA-17840: Move QuotaFactory to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/01 15:31:24 UTC, 2 replies.
- Re: [PR] KAFKA-20338: Add JMH performance benchmarks for KafkaRaftClient [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/07/01 15:34:57 UTC, 50 replies.
- [jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 15:45:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 15:47:00 UTC, 0 replies.
- Re: [PR] MINOR: Update the AK doc to include changes in KIP-1291 [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/01 15:49:07 UTC, 0 replies.
- Re: [PR] KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/07/01 15:59:10 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/01 16:09:00 UTC, 0 replies.
- [PR] MINOR: Prevent overflow in CreateTopics partition validation [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/07/01 16:28:53 UTC, 1 replies.
- Re: [PR] KAFKA-20655: Mark KIP-1331 RPCs stable before release [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/01 16:32:51 UTC, 0 replies.
- [PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/07/01 16:37:22 UTC, 3 replies.
- Re: [PR] KAFKA-20579: Initial producer incremental allocation for uncompressed data [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/07/01 17:48:11 UTC, 12 replies.
- [jira] [Created] (KAFKA-20755) Extend transactional state store test coverage - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 17:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20756) Parameterize integration tests over transactional state stores - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20757) Run store-level unit suites through the transactional path - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20758) Add lifecycle and recovery coverage - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 18:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/01 18:09:54 UTC, 12 replies.
- [jira] [Updated] (KAFKA-20757) Run store-level unit suites through the transactional path - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 18:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20758) Add lifecycle and recovery coverage - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 18:10:00 UTC, 0 replies.
- Re: [PR] KFK-19871: A, Add Builder and Runtime for Multipartition for TopologyTestDriver [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/01 19:09:53 UTC, 0 replies.
- [PR] KFK-19871: Add Runtime to TTD Multipartition [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/01 19:12:45 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/07/01 19:18:00 UTC, 10 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/07/01 19:18:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/01 19:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/01 19:27:00 UTC, 0 replies.
- [PR] KAFKA-20756: Parameterize for transactional state stores [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/01 20:00:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-20760) IQv2 range queries fail and committed Position is lost on restart for transactional state store - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/01 21:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20742) Start offset for newly initialized share partitions should be 0 - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/01 21:24:00 UTC, 0 replies.
- [PR] KAFKA-20760: Fix for Position integration test and persiting Position object [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/01 21:30:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment() - posted by "Colt McNealy (Jira)" <ji...@apache.org> on 2026/07/01 22:05:00 UTC, 0 replies.
- Re: [PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka] - posted by "coltmcnealy-lh (via GitHub)" <gi...@apache.org> on 2026/07/01 22:07:52 UTC, 0 replies.
- [PR] MINOR: handle invalid StreamsHeartbeatRequest [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/01 22:20:54 UTC, 1 replies.
- [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/02 00:02:29 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20741) Add ReadOnlyRecord Interface - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/02 00:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread - posted by "Wang Xiaoqing (Jira)" <ji...@apache.org> on 2026/07/02 02:06:00 UTC, 1 replies.
- Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/07/02 04:20:31 UTC, 6 replies.
- Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/02 04:29:17 UTC, 1 replies.
- Re: [PR] 修复docker jvm构建错误(Fix Docker JVM build errors) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/02 04:49:01 UTC, 1 replies.
- Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/02 04:49:07 UTC, 3 replies.
- Re: [PR] Enhanced mirror maker2 base 4.0.0 for fail-fast and reset handling [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/02 04:49:11 UTC, 0 replies.
- [PR] MINOR: Kafka Streams should log broker provided KIP-1017 config values [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/02 05:18:49 UTC, 4 replies.
- Re: [PR] KAFKA-20703: IQv2 TimestampedKeyWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/02 06:24:48 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/07/02 06:35:00 UTC, 0 replies.
- [PR] KAFKA-13009: do not add global state stores to per-task subtopologies [kafka] - posted by "Aangbaeck (via GitHub)" <gi...@apache.org> on 2026/07/02 07:59:24 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/07/02 08:19:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20032) KIP-1265 : Mechanism for automatic detection of internal API usage - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2026/07/02 09:01:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20032) KIP-1265 : Mechanism for automatic detection of internal API usage - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2026/07/02 09:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20761) Add client logs for consumer group configs defined on the broker - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/02 13:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20761) Add client logs for consumer group configs defined on the broker - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/02 13:13: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/07/02 15:04:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20762) Node replacements are not supported during KRaft migration - posted by "Anton Agestam (Jira)" <ji...@apache.org> on 2026/07/02 15:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Alex (Jira)" <ji...@apache.org> on 2026/07/02 16:14:00 UTC, 13 replies.
- [jira] [Comment Edited] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Alex (Jira)" <ji...@apache.org> on 2026/07/02 16:16:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20763) Mark producer allocation config as public - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/02 17:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20687) Consider improving unused chunks reuse when no data written - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/02 19:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/02 19:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/02 19:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20687) Consider improving unused chunks reuse - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/02 19:36:00 UTC, 1 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 "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/02 19:41:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20765) AsyncKafkaConsumer: OffsetFetch retry on STALE_MEMBER_EPOCH can spin in dedup loop and never complete the application future - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/02 21:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20765) AsyncKafkaConsumer: OffsetFetch retry on STALE_MEMBER_EPOCH can spin in dedup loop and never complete the application future - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/02 21:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20764) StateUpdater moves tasks between collections unatomically which can lead to duplicates - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/02 22:19:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20766) SASL channel authentication may block under slow/broken reverse DNS resolution during connection establishment - posted by "dongfang (Jira)" <ji...@apache.org> on 2026/07/03 02:47:00 UTC, 0 replies.
- [PR] KAFKA-20665: Bump group epoch for warm-up refinement steps [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/03 06:30:32 UTC, 16 replies.
- [PR] KAFKA-20761: Add client logs for consumer group configs defined on the broker [kafka] - posted by "suzhiking (via GitHub)" <gi...@apache.org> on 2026/07/03 07:45:14 UTC, 10 replies.
- Re: [PR] MINOR: Add MockProducer and MockConsumer testing examples [kafka] - posted by "ghost (via GitHub)" <gi...@apache.org> on 2026/07/03 07:50:35 UTC, 0 replies.
- [PR] KAFKA-20760: Parameterise PositionRestartIntegrationTest over transactional mode [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/03 08:28:43 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20665) Add warmup task support to reconciler - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/03 08:56:00 UTC, 1 replies.
- [PR] KAFKA-20762 Add --zk-rollback-compatible flag to kafka-storage.sh format [kafka] - posted by "aiven-anton (via GitHub)" <gi...@apache.org> on 2026/07/03 09:57:01 UTC, 4 replies.
- Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/03 12:37:58 UTC, 0 replies.
- [PR] MINOR: Document connections.max.idle.ms dependency on max.poll.interval.ms for Classic consumer [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/03 12:56:14 UTC, 7 replies.
- Re: [PR] MINOR: Bump Jackson to 2.21.4 [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 13:01:59 UTC, 4 replies.
- [jira] [Created] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2] - posted by "Krishna Chidrawar (Jira)" <ji...@apache.org> on 2026/07/03 13:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/07/03 13:57:34 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2] - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/03 13:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20767) [CVE-2026-54513] , [CVE-2026-54512] [jackson-databind] [2.21.2] - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/03 13:58:00 UTC, 1 replies.
- [PR] KAFKA-19117: Client Throttling Log messages should be of log level - WARN (Java client) [kafka] - posted by "siddharthaDevineni (via GitHub)" <gi...@apache.org> on 2026/07/03 14:08:39 UTC, 3 replies.
- [jira] [Created] (KAFKA-20768) RocksDB SegmentedStore readOnly implementation - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2026/07/03 14:41:00 UTC, 0 replies.
- [PR] KAFKA-20678: Exception handling for read call in ReplicaManagerLogReader.readAsync. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/03 15:37:07 UTC, 1 replies.
- Re: [PR] KAFKA-18448: SSL support for ClusterTestExtensions [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 15:55:26 UTC, 3 replies.
- Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 16:24:58 UTC, 28 replies.
- Re: [PR] KAFKA-19663: kafka-broker-api tool should support to get controller api version [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 16:37:29 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20757) Run store-level unit suites through the transactional path - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/03 16:40:00 UTC, 0 replies.
- Re: [PR] KAFKA-20598: Prevent polling unassigned consumer during ConsumerTask shutdown [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 17:04:36 UTC, 2 replies.
- [PR] KAFKA-20768: Add transactional and IQ isolation to RocksDB window and session stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/03 18:49:20 UTC, 5 replies.
- Re: [PR] KAFKA-20692: Add unit tests for ToolsUtils [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 21:24:35 UTC, 1 replies.
- Re: [PR] KAFKA-20759 testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/03 22:49:57 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/03 22:51:00 UTC, 0 replies.
- Re: [PR] Added support for dynamic SSL certificate reload for controllers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/04 04:18:58 UTC, 0 replies.
- Re: [PR] KAFKA-19491 CONSUMER protocol metrics documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/04 04:19:00 UTC, 13 replies.
- Re: [PR] KAFKA-20734: Return noNode for known partitions without endpoints [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/04 04:19:01 UTC, 0 replies.
- Re: [PR] Enhance mirror maker offsetexception 4.0.0 for silent data loss and topic reset failure. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/04 04:43:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-20769) ListDeserializer can silently deserialize a corrupted entry when the input is truncated mid-entry - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/07/04 07:24:00 UTC, 0 replies.
- [PR] KAFKA-20769: ListDeserializer can silently deserialize a corrupted entry when the input is truncated mid-entry [kafka] - posted by "SEPURI-SAI-KRISHNA (via GitHub)" <gi...@apache.org> on 2026/07/04 07:38:16 UTC, 13 replies.
- [jira] [Created] (KAFKA-20770) LocalLeaderEndPoint returns leader epoch 0 instead of -1 when the epoch cannot be resolved, inconsistent with the ListOffsets-based path - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/07/04 07:46:00 UTC, 0 replies.
- [PR] KAFKA-20770: LocalLeaderEndPoint should return UNDEFINED_EPOCH when the leader epoch cannot be resolved [kafka] - posted by "SEPURI-SAI-KRISHNA (via GitHub)" <gi...@apache.org> on 2026/07/04 07:50:59 UTC, 1 replies.
- [PR] test: cover subscription state validation paths [kafka] - posted by "amirdeljouyi (via GitHub)" <gi...@apache.org> on 2026/07/04 14:49:14 UTC, 1 replies.
- Re: [PR] MINOR: Rewrite AuthorizerIntegrationTest and rename to ConsumerGroupCommandAuthorizationTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/04 20:09:13 UTC, 0 replies.
- Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/04 20:09:52 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20598) Prevent polling unassigned consumer during ConsumerTask shutdown - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/04 20:31:00 UTC, 0 replies.
- [PR] KIP-1320 (PoC): move ByteBufferInputStream to internals behind a deprecated shim [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/05 01:11:11 UTC, 0 replies.
- [PR] KAFKA-18573: Close verification key resolver in BrokerJwtValidator [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/07/05 02:05:41 UTC, 1 replies.
- Re: [PR] KAFKA-18573: Add support for OAuth jwt-bearer grant type [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/07/05 02:06:04 UTC, 0 replies.
- Re: [PR] ci: pin GitHub Actions to full commit SHAs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:28:03 UTC, 3 replies.
- Re: [PR] docs: update 'Testing a Streams Application' example code [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:28:07 UTC, 0 replies.
- Re: [PR] MINOR: Update and align broker/group config "importance" levels (KIP-848/107… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:28:21 UTC, 1 replies.
- Re: [PR] KAFKA-20176: Add MetaProperties V2 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:29:05 UTC, 0 replies.
- Re: [PR] MINOR: UnifiedLog topic-partition as attribute as it is stable [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:48:25 UTC, 1 replies.
- Re: [PR] KAFKA-20135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/05 04:48:29 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20686) DLQ integ tests - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/05 11:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20771) Honor DLQ topic max message bytes so as to not overwhelm it with large produce requests. - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/05 11:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20771) Honor DLQ topic configs so as to not overwhelm it with large produce requests. - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/05 11:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20771) Honor DLQ topic configs so as to not overwhelm it with large produce requests. - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/05 11:20:00 UTC, 0 replies.
- [PR] MINOR: Fix "does not exists" grammatical typos in messages and Javadoc [kafka] - posted by "gaoxiaolei-s59 (via GitHub)" <gi...@apache.org> on 2026/07/05 12:58:27 UTC, 4 replies.
- [PR] MINOR: Fix streams group command options documentation [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/05 14:08:51 UTC, 3 replies.
- [PR] KAFKA-13976: Improve OpenAPI specs for Connect REST API [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/05 16:14:54 UTC, 3 replies.
- [jira] [Commented] (KAFKA-13976) Improvements for OpenAPI specs - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/06 02:17:00 UTC, 0 replies.
- Re: [PR] Add ZSTD compression configuration options [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/06 04:56:43 UTC, 1 replies.
- Re: [PR] KAFKA-20179 : streams - Avoid headers deserialization during changelogging [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/06 04:56:47 UTC, 21 replies.
- Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/06 04:56:49 UTC, 0 replies.
- [jira] [Created] (KAFKA-20772) DLQ System tests - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/06 07:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20246) Detection and handling of misrouted connections - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/06 09:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15828) Protect clients from broker hostname reuse - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/06 09:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20773) [CVE-2026-54515][jackson-databind] - posted by "Krishna Chidrawar (Jira)" <ji...@apache.org> on 2026/07/06 09:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20774) ScramDelta.apply() drops SCRAM users when processing REMOVE records for absent users or multiple removals in one batch - posted by "Mikhail Fomichev (Jira)" <ji...@apache.org> on 2026/07/06 11:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20774) ScramDelta.apply() drops SCRAM users when processing REMOVE records for absent users or multiple removals in one batch - posted by "Mikhail Fomichev (Jira)" <ji...@apache.org> on 2026/07/06 11:13:00 UTC, 1 replies.
- [PR] KAFKA-20774: Fix ScramDelta.apply() dropping SCRAM users [kafka] - posted by "dark231321 (via GitHub)" <gi...@apache.org> on 2026/07/06 11:42:21 UTC, 7 replies.
- Re: [PR] KAFKA-18812: Improve consumer API errors upon background thread failure [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/06 11:47:06 UTC, 5 replies.
- Re: [PR] KAFKA-14228 Support for nested structures: ValueToKey [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/06 12:58:30 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14228) Support for nested structures: ValueToKey - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/06 12:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14228) Support for nested structures: ValueToKey - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/06 12:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-20648: Move Processor object and tests to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/06 13:03:13 UTC, 1 replies.
- Re: [PR] KAFKA-20451: Move RequestChannel Responses to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/06 13:03:24 UTC, 4 replies.
- Re: [PR] KAFKA-20599: Improve retry logic in KafkaStatusBackingStore with exponential backoff [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/06 13:29:25 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20775) Handle the possible incompatibility of `Node#idString` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/06 14:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20775) Handle the possible incompatibility of `Node#idString` - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/06 14:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19117) Client Throttling Log messages should be of log level - WARN (Java client) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/06 14:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19117) Client Throttling Log messages should be of log level - WARN (Java client) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/06 14:15:00 UTC, 0 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/07/06 14:16:51 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20776) MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for KeyQuery and TimestampedKeyQuery - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/06 14:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20776) MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for KeyQuery and TimestampedKeyQuery - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/06 14:26:00 UTC, 0 replies.
- [PR] MINOR: Move RequestChannelTest to server module [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/06 14:29:57 UTC, 1 replies.
- [PR] KAFKA-20297 Move ChildFirstClassLoader, ProducerIdAndEpoch into internal [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/07/06 14:31:17 UTC, 1 replies.
- Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/06 14:34:02 UTC, 0 replies.
- Re: [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/06 14:35:21 UTC, 2 replies.
- [PR] KAFKA-20736: Improve share session handling on leader change [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/06 14:52:06 UTC, 7 replies.
- [jira] [Created] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/06 17:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/06 18:03:00 UTC, 0 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/07/06 18:21:36 UTC, 11 replies.
- [PR] KAFKA-20629: Add ducktape system tests for topology description plugin[2/2] [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/06 18:22:47 UTC, 1 replies.
- [PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/06 18:30:39 UTC, 4 replies.
- Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin[1/2] [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/06 18:52:31 UTC, 0 replies.
- Re: [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka] - posted by "mvanhorn (via GitHub)" <gi...@apache.org> on 2026/07/06 20:12:56 UTC, 0 replies.
- Re: [PR] KAFKA-20197: Headers aware StreamPartitioner [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/06 21:10:57 UTC, 31 replies.
- Re: [PR] KAFKA-20765: Fix OffsetFetch stale-epoch retry spinning in dedup loop [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/06 21:20:41 UTC, 1 replies.
- [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/06 21:36:03 UTC, 6 replies.
- Re: [PR] KAFKA-20661; Implement checking for voter default endpoint [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/07/06 23:30:23 UTC, 1 replies.
- Re: [PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka] - posted by "igloo12 (via GitHub)" <gi...@apache.org> on 2026/07/07 01:28:20 UTC, 0 replies.
- [PR] MINOR: Fix malformed UnifiedLog log messages [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/07/07 02:59:11 UTC, 1 replies.
- [jira] [Created] (KAFKA-20779) followup review on the merged KIP-1265 PR [https://github.com/apache/kafka/pull/21337] - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2026/07/07 03:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20779) followup review on the merged KIP-1265 PR - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2026/07/07 03:58:00 UTC, 1 replies.
- [PR] KAFKA-20779: KIP-1265 review follow-ups from #21337 [kafka] - posted by "ashwinpankaj (via GitHub)" <gi...@apache.org> on 2026/07/07 04:02:44 UTC, 6 replies.
- Re: [PR] MINOR: Document top-level-only field casting limitation in Cast SMT [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/07 04:25:22 UTC, 1 replies.
- Re: [PR] KAFKA-19651: Restore thread interrupted status in consumer close() [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/07 04:47:25 UTC, 0 replies.
- Re: [PR] [TEST] check tags order [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/07 04:47:27 UTC, 0 replies.
- [jira] [Created] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer - posted by "Blaž Šnuderl (Jira)" <ji...@apache.org> on 2026/07/07 07:51:00 UTC, 0 replies.
- [PR] KAFKA: Fix typo in GroupMetadataManagerTest comments (inital -> initial) [kafka] - posted by "DiyaHussein (via GitHub)" <gi...@apache.org> on 2026/07/07 08:10:29 UTC, 0 replies.
- [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2026/07/07 09:35:27 UTC, 9 replies.
- [PR] KAFKA-20627: Add broker integration tests for topology description plugin [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/07 10:24:17 UTC, 2 replies.
- [PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/07 10:56:34 UTC, 4 replies.
- [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/07 11:39:06 UTC, 5 replies.
- Re: [PR] MINOR: Fix missing parenthesis in under-min-ISR trace log [kafka] - posted by "coderbruis (via GitHub)" <gi...@apache.org> on 2026/07/07 11:52:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 13:40:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-18812) Improve new consumer API errors upon background thread failures - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 13:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-18812) Improve new consumer API errors upon background thread failures - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 13:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 14:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/07/07 14:08:00 UTC, 1 replies.
- [PR] KAKFA-XXX: IQ bug under streams protocol [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/07/07 14:32:29 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/07 15:26:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/07 15:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 15:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20773) [CVE-2026-54515][jackson-databind] - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/07 16:34:00 UTC, 1 replies.
- [PR] MINOR: Move Log4jControllerRegistration to server module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/07 16:35:44 UTC, 7 replies.
- Re: [PR] KAFKA-20782: IQ bug under streams protocol [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/07 16:52:08 UTC, 7 replies.
- [jira] [Created] (KAFKA-20783) Integrate async log reader fetch in DelayedShareFetch - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/07 17:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20784) Change certificate management - posted by "David Scrève (Jira)" <ji...@apache.org> on 2026/07/07 17:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/07 18:05:00 UTC, 0 replies.
- [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/07 19:39:28 UTC, 18 replies.
- [jira] [Created] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 20:02:00 UTC, 0 replies.
- [PR] MINOR: mark flaky test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/07 21:21:28 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15104) Flaky test MetadataQuorumCommandTest for method testDescribeQuorumReplicationSuccessful - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 21:22:00 UTC, 0 replies.
- [PR] MINOR: Replace deprecated TopologyTestDriver constructor in TestTopicsTest [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/07/07 21:35:47 UTC, 1 replies.
- [jira] [Created] (KAFKA-20786) Build sometimes times out on streams tests - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/07 22:07:00 UTC, 0 replies.
- [PR] KAFKA-20719: "Streams" group sticky assignor not sticky at startup [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/07 22:58:33 UTC, 1 replies.
- [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/08 03:12:27 UTC, 15 replies.
- [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/07/08 03:55:09 UTC, 7 replies.
- Re: [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:06:23 UTC, 1 replies.
- Re: [PR] KAFKA 18238 - fIdentify the first commit where a test became flaky [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:35:52 UTC, 1 replies.
- Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:35:54 UTC, 2 replies.
- Re: [PR] KAFKA-19615: Enable to ducker-ak to isolate the ducker containers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:35:56 UTC, 1 replies.
- Re: [PR] [WIP] KIP-966: Designated Leadership elections [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:35:58 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/07/08 04:36:01 UTC, 1 replies.
- Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:36:06 UTC, 6 replies.
- Re: [PR] Rlm [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:36:08 UTC, 1 replies.
- Re: [PR] KAFKA-15853: [2/N] Move bulk of remaining configs to AbstractKafkaConfig [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:36:12 UTC, 0 replies.
- Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:36:14 UTC, 2 replies.
- Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/08 04:36:16 UTC, 1 replies.
- [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/08 05:20:58 UTC, 17 replies.
- [jira] [Updated] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933 - posted by "Krishna Chidrawar (Jira)" <ji...@apache.org> on 2026/07/08 05:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/08 12:57:00 UTC, 0 replies.
- Re: [PR] MINOR: mark flaky testDescribeQuorumReplicationSuccessful [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/08 13:10:09 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 14:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/08 14:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20534) Consider decoupling AsyncPollEvent reconciliation trigger and position validation/reset - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 14:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 14:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 14:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/08 16:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/08 16:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 17:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 17:57:00 UTC, 0 replies.
- [PR] KAFKA-16630: Fix flaky classic consumer poll test [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/08 18:37:30 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/08 18:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20786) Build sometimes times out on streams tests - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/08 20:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/08 21:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20788) Expose Rebalance Cause to RebalanceConsumer and Metrics - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/07/08 21:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20788) Expose Rebalance Cause to RebalanceConsumer and Metrics - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/07/08 21:20:00 UTC, 0 replies.
- [PR] KAFKA-20683: Add broker side custom assignors for "streams" groups [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/08 21:35:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/08 23:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/08 23:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20790) Promote streams assignor API to public module - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/08 23:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20790) Promote streams assignor API to public module - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/08 23:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/08 23:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-20693: Fix NPE in AbstractHerder config-validation error handling [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/09 01:37:52 UTC, 1 replies.
- Re: [PR] KAFKA-14229 Support for nested structures: HoistField [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/09 04:25:08 UTC, 1 replies.
- Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/09 04:48:15 UTC, 3 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/07/09 04:48:19 UTC, 1 replies.
- Re: [PR] Question: assumptions around ProduceResponse → ProducerBatch matching [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/09 04:48:26 UTC, 1 replies.
- Re: [PR] KAFKA-5761: Serializer API should support ByteBuffer [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/09 04:48:30 UTC, 1 replies.
- [PR] KAFKA-20597: Fix prefixScan overflow for prefixes with no upper bound in in-memory state stores [kafka] - posted by "edenfunf (via GitHub)" <gi...@apache.org> on 2026/07/09 04:57:14 UTC, 1 replies.
- Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] - posted by "lixuanqun (via GitHub)" <gi...@apache.org> on 2026/07/09 05:21:48 UTC, 0 replies.
- [PR] KAFKA-20786: Bound IntegrationTestUtils.readRecords on real elapsed time [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/09 06:03:57 UTC, 1 replies.
- [PR] KAFKA-19877: Clarify Deserializer ByteBuffer position/limit contract [kafka] - posted by "vismaytiwari (via GitHub)" <gi...@apache.org> on 2026/07/09 06:43:34 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20716) LSO stuck after unclean leader election - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/07/09 06:51:00 UTC, 4 replies.
- [PR] KAFKA-20650: Share ClientQuotaCallback across broker and controller in combined mode [kafka] - posted by "vismaytiwari (via GitHub)" <gi...@apache.org> on 2026/07/09 07:13:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20773) [CVE-2026-54515][jackson-databind] - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/09 09:40:00 UTC, 1 replies.
- [PR] KAFKA-20773: Bump jackson to 2.21.5 [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/09 10:02:16 UTC, 2 replies.
- [jira] [Created] (KAFKA-20791) Bump log4j to 2.25.5 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/09 10:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20791) Bump log4j to 2.25.5 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/09 10:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20791) Bump log4j to 2.25.5 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/09 10:20:00 UTC, 0 replies.
- [PR] KAFKA-20791: Bump log4j to 2.25.5 [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/09 10:21:12 UTC, 2 replies.
- [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/09 10:44:48 UTC, 5 replies.
- Re: [PR] MINOR: Fix typos in GroupMetadataManagerTest comments [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/09 13:12:23 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20741) Add ReadOnlyRecord Interface - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/09 13:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20791) Bump log4j to 2.25.5 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/09 13:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20773) [CVE-2026-54515][jackson-databind] - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/09 14:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20088) CIDR-based Host Patterns for ACLs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/09 14:12:00 UTC, 0 replies.
- Re: [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/07/09 15:17:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/09 15:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1 - posted by "Patrik Kleindl (Jira)" <ji...@apache.org> on 2026/07/09 17:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1 - posted by "Patrik Kleindl (Jira)" <ji...@apache.org> on 2026/07/09 17:40:00 UTC, 4 replies.
- Re: [PR] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/07/09 17:41:22 UTC, 10 replies.
- [PR] MINOR: Document temporal collision window in offset-commit protocol [kafka] - posted by "illyar80 (via GitHub)" <gi...@apache.org> on 2026/07/09 18:11:38 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1 - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/07/09 18:24:00 UTC, 0 replies.
- Re: [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/09 18:41:58 UTC, 1 replies.
- [PR] Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/07/09 19:04:14 UTC, 0 replies.
- [PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/09 19:51:56 UTC, 4 replies.
- [PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/09 20:49:25 UTC, 4 replies.
- [jira] [Updated] (KAFKA-20703) Implement query type 1 (TimestampedKeyWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/09 20:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/09 20:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20704) Implement query type 2 (TimestampedRangeWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/09 20:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20706) Implement query type 4 (TimestampedWindowRangeWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/09 20:52:00 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/07/09 22:19:52 UTC, 0 replies.
- Re: [PR] KAFKA-19200: Recover pre-allocated never-written time index on startup [kafka] - posted by "sidharthdaga (via GitHub)" <gi...@apache.org> on 2026/07/09 22:38:06 UTC, 1 replies.
- [PR] KAFKA-20746 NPE in MetadataCache#toCluster (#22723) [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/07/10 01:44:05 UTC, 0 replies.
- [PR] KAFKA-20746 NPE in MetadataCache#toCluster (4.3) [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/07/10 01:52:43 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Kuan Po Tseng (Jira)" <ji...@apache.org> on 2026/07/10 01:57:00 UTC, 0 replies.
- Re: [PR] KAFKA-20764: Acquire tasksAndActionsLock when moving tasks between maps to avoid issues with concurrency [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/10 04:25:30 UTC, 1 replies.
- Re: [PR] Redistribute request max bytes across remote fetch partitions in DelayedShareFetch [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/10 04:25:32 UTC, 0 replies.
- Re: [PR] KAFKA-14249: Fix flaky TLSv1.3 idle expiry test (Tls13SelectorTest.testCloseOldestConnection) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/10 04:47:12 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20329) Test `headers` dsl.store.format further - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/10 07:47:00 UTC, 0 replies.
- [jira] (KAFKA-20538) Make RocksDB time-ordered buffer headers-aware - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/10 07:48:00 UTC, 0 replies.
- [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/10 07:48:26 UTC, 5 replies.
- Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/10 09:10:26 UTC, 6 replies.
- Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/10 09:40:59 UTC, 14 replies.
- Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/10 09:50:43 UTC, 19 replies.
- Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/10 10:19:44 UTC, 6 replies.
- [jira] [Created] (KAFKA-20793) Mark share.version=2 stable - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/10 11:00:00 UTC, 0 replies.
- [PR] KAFKA-20793: Bump latest production ShareVersion to 2 (SV_2). [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/10 11:18:59 UTC, 1 replies.
- [PR] KAFKA-20783: Completion handling and more tests (3/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/10 11:29:42 UTC, 1 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/07/10 12:44:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/10 12:44:00 UTC, 0 replies.
- Re: [PR] updated request metrics documentation to apply for all APIs [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/10 12:44:26 UTC, 1 replies.
- Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/10 13:28:22 UTC, 42 replies.
- Re: [PR] KAFKA-20746 NPE in MetadataCache#toCluster (4.2) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/10 13:40:54 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20746) NPE in MetadataCache#toCluster - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/10 13:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/10 14:04:44 UTC, 11 replies.
- [jira] [Created] (KAFKA-20794) Add documentation and tests for the RPC deprecatedVersions field - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/10 14:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20451) Move RequestChannel Responses to server module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/10 14:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20179) Avoiding headers deserialization while changelogging - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/10 14:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20179) Avoiding headers deserialization while changelogging - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/10 15:10:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20794) Add documentation and tests for the RPC deprecatedVersions field - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/10 15:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/10 15:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/10 15:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator - posted by "dino2895 (Jira)" <ji...@apache.org> on 2026/07/10 15:34:00 UTC, 0 replies.
- Re: [PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/10 16:10:28 UTC, 4 replies.
- Re: [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/10 16:14:30 UTC, 1 replies.
- [jira] [Created] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/10 17:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/10 17:37:00 UTC, 0 replies.
- [jira] [Assigned] (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 "Vismay (Jira)" <ji...@apache.org> on 2026/07/10 18:57:00 UTC, 0 replies.
- [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka] - posted by "0xffff-zhiyan (via GitHub)" <gi...@apache.org> on 2026/07/10 19:42:33 UTC, 21 replies.
- [PR] let metered store's readonly override with header aware store [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/10 19:44:37 UTC, 0 replies.
- [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/10 19:59:24 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator - posted by "dino2895 (Jira)" <ji...@apache.org> on 2026/07/10 20:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore - posted by "dino2895 (Jira)" <ji...@apache.org> on 2026/07/10 20:52: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/07/10 21:13:04 UTC, 10 replies.
- [PR] KAFKA-20796: Fix num-open-iterators metric for timestamped range queries [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/10 22:16:18 UTC, 3 replies.
- [PR] Reduce lock contention in ProducerMetadata#add [kafka] - posted by "eeriee (via GitHub)" <gi...@apache.org> on 2026/07/10 23:48:54 UTC, 4 replies.
- [PR] MINOR: Rewrite TransactionMetadataTest from Scala to Java [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/11 00:52:28 UTC, 3 replies.
- [jira] [Commented] (KAFKA-18951) Validate client code and documentation in examples/ directory - posted by "Gabriel Dutra (Jira)" <ji...@apache.org> on 2026/07/11 04:18:00 UTC, 0 replies.
- [PR] KAFKA-18951: Correct topic name in client example docs [kafka] - posted by "gvdutra (via GitHub)" <gi...@apache.org> on 2026/07/11 04:18:55 UTC, 1 replies.
- Re: [PR] MINOR: Fix incorrect config name and stale links in Log Compaction docs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/11 04:33:54 UTC, 1 replies.
- Re: [PR] KAFKA-20402: Support broker-side consumer group rebalance callback (KIP-1314) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/11 04:33:57 UTC, 1 replies.
- [PR] MINOR: Fix broken relative links in docs/ [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/07/11 05:46:47 UTC, 3 replies.
- [PR] MINOR: Move ByteBuffer streams to internal package [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/11 12:01:26 UTC, 0 replies.
- [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] - posted by "jim0987795064 (via GitHub)" <gi...@apache.org> on 2026/07/11 14:00:36 UTC, 16 replies.
- Re: [PR] Switch to using scala 2.9.2 [kafka] - posted by "alexanford (via GitHub)" <gi...@apache.org> on 2026/07/11 14:22:07 UTC, 0 replies.
- [jira] [Created] (KAFKA-20797) KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/07/11 14:44:00 UTC, 0 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/07/11 16:35:09 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/07/11 16:42:00 UTC, 0 replies.
- Re: [PR] KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/11 16:44:56 UTC, 1 replies.
- Re: [PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka] - posted by "kumarlokesh (via GitHub)" <gi...@apache.org> on 2026/07/11 18:13:15 UTC, 0 replies.
- Re: [PR] KAFKA-19010: Added JVM argument to default configuration [kafka] - posted by "kumarlokesh (via GitHub)" <gi...@apache.org> on 2026/07/11 18:13:43 UTC, 0 replies.
- [PR] KAFKA-20781: Fix flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/11 21:32:59 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/07/11 22:05:00 UTC, 0 replies.
- [PR] KAFKA-4637: Add system test for multiple listeners [kafka] - posted by "maskedmaxx (via GitHub)" <gi...@apache.org> on 2026/07/12 01:59:31 UTC, 1 replies.
- [jira] [Assigned] (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/07/12 04:04:00 UTC, 0 replies.
- Re: [PR] KIP-1320 (PoC): deprecate Utils behind an internal implementation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:15:23 UTC, 2 replies.
- Re: [PR] MINOR: optimize cooperative assignment validation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:15:43 UTC, 0 replies.
- Re: [PR] KAFKA-14227 Support for nested structures: MaskField [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:16:10 UTC, 0 replies.
- Re: [PR] KAFKA-20538: Make RocksDBTimeOrderedKeyValueBuffer headers-aware [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:16:16 UTC, 2 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/07/12 04:39:03 UTC, 2 replies.
- Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:39:05 UTC, 0 replies.
- Re: [PR] KAFKA-18053 Clean up topology config [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:39:07 UTC, 1 replies.
- Re: [PR] KAFKA-19881: change CVE scanner workflow to run on active branches (wip) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/12 04:39:09 UTC, 0 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/07/12 04:39:11 UTC, 2 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/07/12 04:39:15 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path - posted by "Karsten Stöckmann (Jira)" <ji...@apache.org> on 2026/07/12 12:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20766) SASL channel authentication may block under slow/broken reverse DNS resolution during connection establishment - posted by "dongfang (Jira)" <ji...@apache.org> on 2026/07/12 13:23:00 UTC, 0 replies.
- [PR] KAFKA-20568: Unify DSL store accessor and header-aware builder naming [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/12 15:38:42 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/07/12 16:52:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/12 21:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/12 23:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-19470 Avoid creating loggers repeatedly to affect the performance of request processing [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/13 04:41:29 UTC, 2 replies.
- Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/13 04:41:37 UTC, 1 replies.
- Re: [PR] KAFKA-20297: Move `org.apache.kafka.common.utils.Utils` to `org.apache.kafka.common.utils.internals.Utils` [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/13 04:41:43 UTC, 1 replies.
- [PR] MINOR: Enhance MirrorMaker 2 fault tolerance for topic truncation and reset scenarios [kafka] - posted by "ankita10r (via GitHub)" <gi...@apache.org> on 2026/07/13 07:21:00 UTC, 0 replies.
- [PR] KAFKA-10369: Add TimestampAndOffset value type of deduplication store (1/N) [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2026/07/13 07:59:51 UTC, 1 replies.
- [jira] [Created] (KAFKA-20799) Introduce new error for consumer/share group name collision - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/07/13 08:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/07/13 08:04:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20797) KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2026/07/13 08:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20629) Add ducktape system tests for topology description plugin - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/07/13 08:53:00 UTC, 0 replies.
- Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] - posted by "nachogiljaldo (via GitHub)" <gi...@apache.org> on 2026/07/13 09:28:25 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20799) Introduce new error for consumer/share group name collision - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/13 09:56:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20799) Introduce new error for consumer/share group name collision - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/07/13 10:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20761) Add client logs for consumer group configs defined on the broker - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/13 11:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20800) Adjust Kafka security logging with more context - posted by "Vladimir Yatsenko (Jira)" <ji...@apache.org> on 2026/07/13 12:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20009) Top level pages should include short descriptions for each section - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/07/13 12:49:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores - posted by "Hannes Buseyne (Jira)" <ji...@apache.org> on 2026/07/13 13:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/13 14:07:00 UTC, 2 replies.
- Re: [PR] MINOR: Move ByteBufferInputStream and ByteBufferOutputStream to internal package [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/13 14:14:39 UTC, 0 replies.
- Re: [PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/13 14:15:52 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-20771) Honor DLQ topic configs so as to not overwhelm it with large produce requests. - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/13 14:41:00 UTC, 0 replies.
- [PR] KAFKA-20698: Remove deprecated ConsumerRecords(Map) constructor [kafka] - posted by "asdf2014 (via GitHub)" <gi...@apache.org> on 2026/07/13 14:56:20 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20723) Harden ShareGroupDLQStateManager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/13 15:07:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 16:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/13 16:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/13 16:49:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/13 16:52:00 UTC, 0 replies.
- Re: [PR] KAFKA-20777: Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/13 16:55:18 UTC, 2 replies.
- Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/13 17:48:08 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/13 19:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/13 20:36:00 UTC, 0 replies.
- Re: [PR] KAFKA-20032: KIP-1265 Automatic detection of internal API usage [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/13 20:42:12 UTC, 3 replies.
- Re: [PR] docs: add Oxford comma in README.md project list [kafka] - posted by "koteshyelamati (via GitHub)" <gi...@apache.org> on 2026/07/13 20:49:03 UTC, 0 replies.
- Re: [PR] KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/13 21:01:27 UTC, 2 replies.
- [PR] KAFKA-20757: Expand transactional state-store unit-test coverage [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/07/13 21:06:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 21:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 21:14:00 UTC, 0 replies.
- [jira] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 22:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 22:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 22:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/13 22:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-20744: Add back `rack.aware.assignment.tags` config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/13 22:41:00 UTC, 13 replies.
- [PR] KAFKA-20760: Break out PositionRestartIntegrationTest into sub-class for transactional stores [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/13 23:09:30 UTC, 2 replies.
- Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/14 01:27:10 UTC, 35 replies.
- [jira] [Assigned] (KAFKA-20786) Build sometimes times out on streams tests - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/14 01:47:00 UTC, 0 replies.
- [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/14 02:02:57 UTC, 2 replies.
- Re: [PR] KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/14 04:30:25 UTC, 0 replies.
- Re: [PR] KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/14 04:30:29 UTC, 1 replies.
- Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/14 04:30:32 UTC, 1 replies.
- Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/14 04:30:40 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9613) CorruptRecordException: Found record size 0 smaller than minimum record overhead - posted by "Santosh Kumar Sahu (Jira)" <ji...@apache.org> on 2026/07/14 06:08:00 UTC, 0 replies.
- [PR] MINOR: Correct broker dynamic configuration names in the documentation [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/14 08:35:46 UTC, 1 replies.
- [jira] [Created] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/07/14 09:59:00 UTC, 0 replies.
- [PR] KAFKA-20667: Add principal-level index to AclCache to fix O(N) ACL scanning [kafka] - posted by "Chhida (via GitHub)" <gi...@apache.org> on 2026/07/14 10:04:25 UTC, 1 replies.
- Re: [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/07/14 10:05:16 UTC, 0 replies.
- Re: [PR] HOTFIX: Reduce lock contention in ProducerMetadata#add [kafka] - posted by "gnarula (via GitHub)" <gi...@apache.org> on 2026/07/14 10:49:36 UTC, 1 replies.
- [PR] KAFKA-20802: Skip terminated threads when building thread leak reports [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/14 10:59:09 UTC, 1 replies.
- [PR] KAFKA-20783: Clear held partitions failing min-bytes (4/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/14 11:03:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/14 11:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20577) Producer configuration to define allocation strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/14 11:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/14 11:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/14 11:44:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20704) Implement query type 2 (TimestampedRangeWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/14 12:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/14 13:01:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/14 13:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20768) RocksDB SegmentedStore readOnly implementation - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/14 13:05:00 UTC, 0 replies.
- Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1071 config values [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/14 13:38:54 UTC, 5 replies.
- [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/14 16:18:32 UTC, 5 replies.
- [PR] KAFKA-20783: Release locks on exception for local reads within remote calls (5/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/14 17:41:11 UTC, 2 replies.
- [jira] [Created] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/07/14 18:00:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/07/14 18:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/07/14 18:57:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Xi Wang (Jira)" <ji...@apache.org> on 2026/07/14 19:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Xi Wang (Jira)" <ji...@apache.org> on 2026/07/14 19:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/14 19:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/14 19:56:00 UTC, 0 replies.
- [PR] KAFKA-19979: Improve Kafka Streams config files [kafka] - posted by "peterzdhuang (via GitHub)" <gi...@apache.org> on 2026/07/14 20:48:27 UTC, 8 replies.
- [jira] [Created] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore and OffsetOutOfRange after a StreamThread failure - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/14 22:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/14 22:19:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-15513) KRaft cluster fails with SCRAM authentication enabled for control-plane - posted by "Aditya Mohanty (Jira)" <ji...@apache.org> on 2026/07/14 22:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15513) KRaft cluster fails with SCRAM authentication enabled for control-plane - posted by "Aditya Mohanty (Jira)" <ji...@apache.org> on 2026/07/14 22:24:00 UTC, 3 replies.
- [PR] KAFKA-20805: Check for last commit time by task vs. using directory mtime alone [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/14 22:39:13 UTC, 4 replies.
- Re: [PR] KAFKA-20802: Avoid NPE in thread leak reporting [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/15 00:33:23 UTC, 1 replies.
- Re: [PR] KAFKA-20578: Initial producer incremental allocation for uncompressed data [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/07/15 00:41:11 UTC, 62 replies.
- Re: [PR] KAFKA-20673: Skip stale-leader lookup retry while the AdminClient is closing (follow-up) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/15 02:17:45 UTC, 1 replies.
- [PR] MINOR: reduce Kafka Streams integration test runtime [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/15 02:23:44 UTC, 2 replies.
- [PR] MINOR: Correct the documented default for automatic ConfigProviders [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/15 03:37:48 UTC, 1 replies.
- Re: [PR] KAFKA-20649: KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/15 04:05:34 UTC, 0 replies.
- [PR] KAFKA-20803: Demultiplex batched persister responses once (WriteStateHandler) [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/07/15 04:25:27 UTC, 8 replies.
- Re: [PR] KAFKA-20025: enable dynamic TLS reconfiguration for KafkaRaftManager [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/15 04:30:35 UTC, 3 replies.
- Re: [PR] KAFKA-20343: Refactor LogCleanerLagIntegrationTest to use a builder for LogCleaner setup [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/15 04:30:38 UTC, 0 replies.
- [PR] KAFKA-20253 Heartbeat CPU spin fix for Consumer protocol [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/07/15 06:19:01 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/15 09:13:00 UTC, 3 replies.
- [PR] KAFKA-20805: Refresh task directory mtime on state manager close [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/15 10:06:16 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol - posted by "Daniel Hongerlood (Jira)" <ji...@apache.org> on 2026/07/15 10:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20715) Cluster Mirroring - Synchronous mode - posted by "Mahesh Sambaram (Jira)" <ji...@apache.org> on 2026/07/15 11:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed() - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/15 12:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed() - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/15 12:23:00 UTC, 2 replies.
- [PR] MINOR: Clarify controller bootstrap support in admin CLI documentation [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/15 12:28:43 UTC, 1 replies.
- [PR] MINOR: Correct the deprecated console share consumer option in the 4.3 upgrade notes [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/15 12:36:31 UTC, 2 replies.
- [PR] MINOR: Align failed-push expiration test with UNCERTAIN reclaim [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/15 12:46:25 UTC, 0 replies.
- Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/15 13:18:53 UTC, 3 replies.
- [PR] MINOR: Updated log reader interface to abstractions [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/15 13:31:41 UTC, 3 replies.
- Re: [PR] KAFKA-19483 : Fix resource leak, cleanup [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/15 13:47:34 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/15 14:41:00 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 "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/07/15 17:44:47 UTC, 0 replies.
- [PR] MINOR: fix DOAP metadata — git repo declared as SVNRepository; add Java to programming languages [kafka] - posted by "kobihikri (via GitHub)" <gi...@apache.org> on 2026/07/15 17:52:33 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed() - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/15 19:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V - posted by "Wojciech Suski (Jira)" <ji...@apache.org> on 2026/07/15 19:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-20806: Align failed-push expiration test with UNCERTAIN reclaim [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/15 19:23:40 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20805) State directory cleaned prematurely under KIP-1035, forcing from-scratch restore - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/15 20:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20807) Refactor ByteBufferOutputStream for better extensibility - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/15 20:29:00 UTC, 0 replies.
- [PR] KAFKA-20807: Refactor ByteBufferOutputStream for extensibility (for KIP-1332) [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/15 20:49:59 UTC, 4 replies.
- [PR] KAFKA-20805: Apply fix for refreshing task directory mtime on state manager close on 4.3 [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/15 21:34:14 UTC, 1 replies.
- [PR] MINOR: fix flakey SwallowUnknownTopicErrorIntegrationTest [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/15 22:38:49 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/15 22:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/07/15 23:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-20711: Measure restore progress in offset slots [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/15 23:58:15 UTC, 2 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/07/16 00:57:40 UTC, 1 replies.
- [PR] MINOR: Correct KRaft command options and controller metric classifications [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/16 01:37:45 UTC, 1 replies.
- [PR] MINOR: Correct configuration property names in the Kafka Connect ACL tables [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/16 01:53:06 UTC, 1 replies.
- Re: [PR] KAFKA-20583 - Added support for dynamic SSL certificate reload for controllers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/16 04:05:16 UTC, 0 replies.
- Re: [PR] KAFKA-19070: add taskId to consumer override clientId [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/16 04:32:59 UTC, 1 replies.
- Re: [PR] KAFKA−17999: Fix flaky test DynamicConnectionQuotaTest.testDynamicConnectionQuota [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/16 04:33:02 UTC, 1 replies.
- Re: [PR] kafka - 19409: Upgrade RocksDB to 10.5.1 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/16 04:33:08 UTC, 0 replies.
- Re: [PR] [POC] KAFKA-20171: Kafka Streams use topic ids. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/16 04:33:12 UTC, 0 replies.
- [PR] MINOR: MM2 fail-fast on source data loss and topic reset [kafka] - posted by "Vineet-kumar8757 (via GitHub)" <gi...@apache.org> on 2026/07/16 05:51:47 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20806) Failing Test: TopologyDescriptionPluginExpirationIntegrationTest > shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed() - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/07/16 08:39:00 UTC, 0 replies.
- [PR] MINOR: Fix DLQ records using a non-epoch clock for their timestamp [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/16 10:28:47 UTC, 1 replies.
- Re: [PR] KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/16 11:35:41 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-19663) kafka-broker-api tool should support to get controller api version - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/16 11:39:00 UTC, 0 replies.
- [PR] MINOR: Update quota examples to match current kafka-configs output [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/16 12:10:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/16 13:06:00 UTC, 0 replies.
- [PR] KAFKA-20772 (2/n): Add multi-partition and multi-topic DLQ system tests [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/16 14:48:14 UTC, 5 replies.
- [PR] Detect data loss and topic reset in MirrorMaker 2 source task [kafka] - posted by "ldhruva987 (via GitHub)" <gi...@apache.org> on 2026/07/16 15:40:49 UTC, 1 replies.
- [PR] KAFKA-20706: IQv2 TimestampedWindowRangeWithHeadersQuery (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/16 17:52:19 UTC, 10 replies.
- Re: [PR] KAFKA-20760: Fix for PositionRestartIntegrationTest and persisting Position object [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/16 18:52:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19622) Limitations of KRAFT Dual Write Mode for Production Support - posted by "David Arthur (Jira)" <ji...@apache.org> on 2026/07/16 19:57:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19622) Limitations of KRAFT Dual Write Mode for Production Support - posted by "David Arthur (Jira)" <ji...@apache.org> on 2026/07/16 20:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20609) Use the lastModifiedTime to replace furture timestamp in deleting retentions - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/07/16 21:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18951) Validate client code and documentation in examples/ directory - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/16 22:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18951) Validate client code and documentation in examples/ directory - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/16 22:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-967 Use key range in ProducerPerformance [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/16 22:32:38 UTC, 5 replies.
- [PR] KAFKA-20553: Remove storage dependency on core test output [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/16 23:24:44 UTC, 9 replies.
- [jira] [Created] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/17 01:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/17 01:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/17 01:11:00 UTC, 1 replies.
- [PR] KAFKA-20808: StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/17 01:46:55 UTC, 4 replies.
- Re: [PR] (WIP) KAFKA-19261 Move ConnectionQuotas to server module [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/17 04:33:31 UTC, 1 replies.
- Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/17 04:33:37 UTC, 2 replies.
- Re: [PR] KAFKA-4094: Reclassify broker configs that have sensible defaults as MEDIUM importance [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/17 04:33:47 UTC, 1 replies.
- [PR] MINOR: Fix regex escaping in Kafka Streams WordCount examples [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/17 07:50:40 UTC, 1 replies.
- [PR] MINOR: Fix certificate signing request commands in the SSL documentation [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/17 07:56:37 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-20723) Harden ShareGroupDLQStateManager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/17 09:05:00 UTC, 0 replies.
- [PR] KAFKA-20772 (3/n): Add ducktape system tests for share group DLQ with tiered storage [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/17 09:11:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-20809) Update documentation with KIP-1191 information - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/17 09:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-20711: Measure restore-remaining-records in offset slots [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/17 10:47:59 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor - posted by "viveak vagalaboina (Jira)" <ji...@apache.org> on 2026/07/17 11:36:00 UTC, 1 replies.
- [PR] KAFKA-20413: Add missing headers-aware ListValueStore [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/17 15:09:52 UTC, 0 replies.
- [jira] [Created] (KAFKA-20810) Client framework name and version - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/17 15:33: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/07/17 17:04:00 UTC, 1 replies.
- [PR] WIP: KAFKA-XXXX Fault injection proxy [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/17 18:00:16 UTC, 0 replies.
- Re: [PR] Kip 1340 poc [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/17 18:38:55 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20808) StreamThread dies with fatal InvalidStateStoreException after TaskCorruptedException - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/17 19:45:00 UTC, 0 replies.
- [PR] KAFKA-20795: Generate RequestConvertToJson request and response methods [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/17 21:56:14 UTC, 1 replies.
- [PR] KAFKA-12570: Document compact arrays in flexible versions [kafka] - posted by "gvdutra (via GitHub)" <gi...@apache.org> on 2026/07/18 03:05:20 UTC, 2 replies.
- Re: [PR] [WIP]KAFKA-19000 Flaky test report should use absolute time for links [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/18 04:29:19 UTC, 1 replies.
- Re: [PR] KAFKA-19106 : Improve SourceTask commit() hook [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/18 04:29:20 UTC, 1 replies.
- Re: [PR] Kafka changes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/18 04:29:24 UTC, 1 replies.
- Re: [PR] MINOR: code cleanup group coordinator [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/18 04:29:34 UTC, 1 replies.
- [PR] fix: upgrade http:// to https:// in README.md [kafka] - posted by "hanu-14 (via GitHub)" <gi...@apache.org> on 2026/07/18 05:41:01 UTC, 4 replies.
- [PR] KAFKA-20731: Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread [kafka] - posted by "arnabnandy7 (via GitHub)" <gi...@apache.org> on 2026/07/18 13:59:43 UTC, 3 replies.
- [PR] KAFKA-20728: Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154) [kafka] - posted by "arnabnandy7 (via GitHub)" <gi...@apache.org> on 2026/07/18 14:44:44 UTC, 1 replies.
- [jira] [Created] (KAFKA-20811) Add connector plugin version configuration and validation tests - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/18 16:50:00 UTC, 0 replies.
- [PR] KAFKA-20811: Add connector plugin version configuration and validation tests [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/18 17:03:04 UTC, 1 replies.
- Re: [PR] KAFKA-20772 (3/3): Add ducktape system tests for share group DLQ with tiered storage [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/18 17:49:01 UTC, 0 replies.
- Re: [PR] KAFKA-17921: Support SASL_PLAINTEXT protocol with java.security.auth.login.config [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/18 21:52:24 UTC, 0 replies.
- Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/18 22:02:27 UTC, 0 replies.
- Re: [PR] MINOR: Rewrite SaslClientsWithInvalidCredentialsTest and rename to ConsumerGroupCommandSaslAuthenticationTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/18 22:36:24 UTC, 0 replies.
- [PR] MINOR: Move JaasModule into JaasUtils [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/18 22:44:14 UTC, 4 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/07/18 22:59:49 UTC, 2 replies.
- [PR] MINOR: Remove redundant bcpkix test dependency from tools module [kafka] - posted by "hjtiun852 (via GitHub)" <gi...@apache.org> on 2026/07/18 23:49:27 UTC, 2 replies.
- [PR] KAFKA-20804: Cut lock contention in metadata add() [kafka] - posted by "1230fahid (via GitHub)" <gi...@apache.org> on 2026/07/19 00:40:29 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 00:42:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16835) Add Support for consumer to read in commit order. - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 00:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 00:54:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Xi Wang (Jira)" <ji...@apache.org> on 2026/07/19 01:38:00 UTC, 0 replies.
- [PR] KAFKA-20709: Add HeaderRouter SMT [kafka] - posted by "1230fahid (via GitHub)" <gi...@apache.org> on 2026/07/19 03:14:51 UTC, 1 replies.
- Re: [PR] Refactor code to avoid discovery conflicts for classes:{Supported|Finalized}VersionRange [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/19 04:37:32 UTC, 1 replies.
- Re: [PR] [POC] KAFKA-20171: Kafka Streams use topic ids. (other version) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/19 04:37:47 UTC, 1 replies.
- Re: [PR] KAFKA-19595 Added configuration validation option to Kafka server sta… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/19 04:37:50 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16680) Make ClusterTestExtensions support SASL - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 07:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18448) Support SSL protocol with java.security.auth.login.config - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 07:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20812) refactor KRaftClusterTest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 07:30:00 UTC, 0 replies.
- [PR] KAFKA-20553: Use ClusterInstance for streams AbstractResetIntegrationTest [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/19 09:25:50 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15165) Handle Kafka client certificate failures without impacting brokers - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 09:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20784) Change certificate management - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 09:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15165) Handle Kafka client certificate failures without impacting brokers - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 09:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1579) End-to-End tool to measure performance and correctness test - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 10:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/19 10:13:00 UTC, 0 replies.
- [PR] MINOR: Unify ClusterInstance client security configuration [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/19 12:11:38 UTC, 0 replies.
- [PR] KAFKA-20609 : Use lastModified time as retention anchor for future-timestamped segments [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/19 13:45:33 UTC, 1 replies.
- [PR] KAFKA-20812: Move parts of KRaftClusterTest to clients-integration-tests [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/19 17:56:03 UTC, 7 replies.
- [jira] [Created] (KAFKA-20813) docker_build_test.py doesn't like podman - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 19:42:00 UTC, 0 replies.
- [PR] KAFKA-20812: Move Admin tests from KRaftClusterTest [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/19 21:03:52 UTC, 10 replies.
- [jira] [Created] (KAFKA-20814) Make Time utils class part of the public API - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 21:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17939) Kafka Streams API exposes org.apache.kafka.common.utils.Bytes which is not part of the public API - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 21:54:00 UTC, 1 replies.
- [PR] MINOR: Clean up SSL support for ClusterTestExtensions [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/19 22:24:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20814) Make Time utils class part of the public API - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/19 22:57:00 UTC, 0 replies.
- [PR] Task 1 implementation done [kafka] - posted by "techchefsouho99 (via GitHub)" <gi...@apache.org> on 2026/07/20 03:06:34 UTC, 1 replies.
- Re: [PR] KAFKA-19839: Fix NoSuchFieldError for zstd compression in native image [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/20 04:44:07 UTC, 4 replies.
- Re: [PR] KAFKA-20454: Prevent offset reset for streams groups in kafka-consumer-groups.sh [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/20 04:44:12 UTC, 0 replies.
- Re: [PR] KAFKA-20464: Fix topology corruption when ConnectedStoreProviders share a StoreBuilder [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/20 04:44:14 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/07/20 04:59:00 UTC, 0 replies.
- [PR] MINOR: Fix RandomAccessFile leak in FileRecords.openChannel [kafka] - posted by "david-simon (via GitHub)" <gi...@apache.org> on 2026/07/20 06:53:41 UTC, 1 replies.
- [PR] MINOR: Correct the default Kafka Connect protocol mode in the administration guide [kafka] - posted by "popsunlake (via GitHub)" <gi...@apache.org> on 2026/07/20 07:53:36 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/20 08:48:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/07/20 09:00:00 UTC, 0 replies.
- [PR] MINOR: Cache SASL principal per authentication [kafka] - posted by "nandini12396 (via GitHub)" <gi...@apache.org> on 2026/07/20 09:16:30 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20772) DLQ System tests - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/07/20 09:17:00 UTC, 0 replies.
- [PR] KAFKA-20783: Fixes for locks release for async handling in DelayedShareFetch (6/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/20 09:40:07 UTC, 5 replies.
- [jira] [Commented] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/20 10:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/20 10:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller - posted by "Fahid Abdullah (Jira)" <ji...@apache.org> on 2026/07/20 10:28:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4] - posted by "Krishna Chidrawar (Jira)" <ji...@apache.org> on 2026/07/20 11:42:00 UTC, 0 replies.
- Re: [PR] KAFKA-19871: Add Runtime to TTD Multipartition [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/20 13:06:39 UTC, 14 replies.
- [PR] KAFKA-20682: Document IQv2 headers-aware queries (KIP-1356) [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/20 13:18:06 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20709) Add built-in SMT for header-based topic routing in Kafka Connect / MirrorMaker 2 with configurable priority across multiple headers - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/20 14:31:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154) - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/20 14:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154) - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/20 14:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20816) Add CIDR support also into Authorizer.authorizeByResourceType - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/07/20 14:47:00 UTC, 0 replies.
- [PR] KAFKA-20816: Add support for CIDR into Authorizer.authorizeByResourceType [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/07/20 14:58:27 UTC, 6 replies.
- Re: [PR] KAFKA-20658: Cast SMT honors ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/07/20 15:53:54 UTC, 1 replies.
- Re: [PR] KAFKA-20657: JsonConverter BYTES uses ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/07/20 15:53:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/20 16:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/20 16:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/20 16:56:00 UTC, 0 replies.
- [PR] KAFKA-20553: Remove clients-integration-tests dependency on core test output [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/20 17:10:47 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-20783) Integrate async log reader fetch in DelayedShareFetch - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/20 17:31:00 UTC, 0 replies.
- [PR] MINOR: Reduce DescribeStreamsGroupTest execution time [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/20 17:49:56 UTC, 1 replies.
- [PR] KAFKA-28013 Add Podman support to Docker image build tests [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/20 19:07:24 UTC, 1 replies.
- [PR] MINOR: increase build timeout to 3.5 hours [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/20 19:14:39 UTC, 3 replies.
- [PR] KAFKA-20736: Close empty share sessions safely [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/20 19:43:40 UTC, 10 replies.
- [PR] MINOR: Fix KStream KStream-GlobalKTable leftJoin doc and test param inaccuracy for KIP-1340 [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/20 21:37:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-20817) Add more ducktape system tests scenarios for topology description plugin - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/20 21:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20817) Add more ducktape system tests scenarios for topology description plugin - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/20 22:00:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix KStream leftJoin doc and test param naming for KStream-GlobalKTable [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/20 22:11:45 UTC, 7 replies.
- [jira] [Updated] (KAFKA-20438) Allow dropping "future" records - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/20 23:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19726) Throw an exception if client tries to override topic replication factor with a value that it < min.insync.replicas - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/21 00:00:00 UTC, 0 replies.
- Re: [PR] MINOR: Narrow remote copy lag validator props to Map and update the upgrade doc for KIP-1241 [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/07/21 02:50:41 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/07/21 02:56:40 UTC, 0 replies.
- Re: [PR] Started on work [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/21 04:35:55 UTC, 1 replies.
- Re: [PR] KAFKA-20437: Fix ssl.enabled.protocols dynamic reconfiguration not being applied [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/21 04:36:03 UTC, 1 replies.
- Re: [PR] KAFKA-20448: Fix Docker JVM image build when using local kafka archive [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/21 04:36:05 UTC, 1 replies.
- [jira] [Created] (KAFKA-20818) Kafka Mirror Maker latency increase intermittently - posted by "Vinayagam Rajanbabu (Jira)" <ji...@apache.org> on 2026/07/21 05:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20818) Kafka Mirror Maker latency increase intermittently - posted by "Vinayagam Rajanbabu (Jira)" <ji...@apache.org> on 2026/07/21 05:10:00 UTC, 0 replies.
- [PR] KAFKA-20722: Upgrade JLine to 3.30.14 [kafka] - posted by "qiuyanjun888 (via GitHub)" <gi...@apache.org> on 2026/07/21 07:13:49 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933 - posted by "Qiu Yanjun (Jira)" <ji...@apache.org> on 2026/07/21 07:16:00 UTC, 0 replies.
- [PR] KAFKA-20783: Minor change to include try/finally block for locks release [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/21 08:12:24 UTC, 1 replies.
- [PR] KFK-19871: Update test with new TopologyTestDriverBuilder [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/21 08:27:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group - posted by "Stanislav Savulchik (Jira)" <ji...@apache.org> on 2026/07/21 10:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20820) Broker fails to start when log.dirs is a symbolic link - posted by "Gergely Harmadás (Jira)" <ji...@apache.org> on 2026/07/21 11:18:00 UTC, 0 replies.
- [PR] KAFKA-20820: make symlinked log.dirs possible when on JDK17 [kafka] - posted by "harmadasg (via GitHub)" <gi...@apache.org> on 2026/07/21 11:20:30 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20821) kafka-delete-records.sh exits 0 even when some partitions fail to delete - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/07/21 12:47:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20821) kafka-delete-records.sh exits 0 even when some partitions fail to delete - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/07/21 12:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20821) kafka-delete-records.sh exits 0 even when some partitions fail to delete - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/07/21 12:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4] - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/21 12:51:00 UTC, 3 replies.
- [PR] KAFKA-20821: DeleteRecordsCommand exits non-zero on per-partition errors [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2026/07/21 13:07:19 UTC, 1 replies.
- [PR] KFK-19871: Add Runtime interface [kafka] - posted by "sebastienviale (via GitHub)" <gi...@apache.org> on 2026/07/21 13:14:13 UTC, 0 replies.
- [jira] [Created] (KAFKA-20822) Trogdor uses insecure Jackson Polymorphic Id.CLASS setting - posted by "PJ Fanning (Jira)" <ji...@apache.org> on 2026/07/21 14:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4] - posted by "Gergely Harmadás (Jira)" <ji...@apache.org> on 2026/07/21 14:52:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20815) Security : [jline-remote-telnet] [3.30.4] - posted by "Gergely Harmadás (Jira)" <ji...@apache.org> on 2026/07/21 14:53:00 UTC, 0 replies.
- Re: [PR] KAFKA-20656: Struct honors ByteBuffer remaining bytes [kafka] - posted by "BK202503 (via GitHub)" <gi...@apache.org> on 2026/07/21 14:58:17 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20822) Trogdor uses insecure Jackson Polymorphic Id.CLASS setting - posted by "PJ Fanning (Jira)" <ji...@apache.org> on 2026/07/21 15:29:00 UTC, 0 replies.
- [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable (2/2) [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/21 15:42:59 UTC, 6 replies.
- [PR] KAFKA-20815: Remove unnecessary jline deps and bump to latest 3.x [kafka] - posted by "harmadasg (via GitHub)" <gi...@apache.org> on 2026/07/21 16:13:21 UTC, 8 replies.
- [PR] KAFKA-20553: Remove tools module dependency on core test output [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/21 16:26:28 UTC, 3 replies.
- [PR] MINOR: Fix native image startup with share group DLQ manager [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/21 16:56:22 UTC, 1 replies.
- [PR] Refactor - Consolidate process-and-verify helpers, PART-2 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/21 20:30:52 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20769) ListDeserializer can silently deserialize a corrupted entry when the input is truncated mid-entry - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/21 21:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20665) Add warmup task support to reconciler - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/21 22:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20823) Relax null-value restriction in Kafka Streams joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/21 23:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20823) Relax null-value restriction in Kafka Streams joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/21 23:27:00 UTC, 1 replies.
- [PR] MINOR: Set StreamThread to daemon [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/21 23:29:12 UTC, 2 replies.
- [jira] [Created] (KAFKA-20824) CI ought to test native image - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19839) Native-image (dockerimage) does not work with compression.type=zstd - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19583) Native docker image fails to start when using SASL OAUTHBEARER mechanism - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20314) Segmentation fault when starting kafka-native - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19584) Native docker image authentication fails with SASL PLAIN - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20825) Native image can't work due to missing DefaultShareGroupDLQManager - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/21 23:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-20825 Fix native image startup with share group DLQ manager [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/21 23:45:40 UTC, 3 replies.
- [PR] MINOR: cleanup build.gradle unused dependency (WIP) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/22 01:55:17 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20825) Native image can't work due to missing DefaultShareGroupDLQManager - posted by "dino2895 (Jira)" <ji...@apache.org> on 2026/07/22 03:27:00 UTC, 0 replies.
- Re: [PR] KAFKA-17259: Support to override serverProperties and restart cluster in ClusterTestExtensions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:44 UTC, 0 replies.
- Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:46 UTC, 2 replies.
- Re: [PR] KAFKA-18981: Fix flaky QuorumControllerTest.testMinIsrUpdateWithElr [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:47 UTC, 0 replies.
- Re: [PR] KAFKA-19909: Add rack awareness assignment to UniformHomogeneousAssignmentBuilder [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:49 UTC, 0 replies.
- Re: [PR] docs: clarify log compaction with example and tombstone explanation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:51 UTC, 1 replies.
- Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/22 04:36:55 UTC, 6 replies.
- [jira] [Commented] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group - posted by "Stanislav Savulchik (Jira)" <ji...@apache.org> on 2026/07/22 04:52:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/22 05:53:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/22 09:29:00 UTC, 0 replies.
- Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/22 09:49:23 UTC, 3 replies.
- Re: [PR] MINOR: Cleanup build.gradle unused dependency [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/22 10:13:14 UTC, 8 replies.
- [jira] [Created] (KAFKA-20826) EndToEndLatencyTest#testInvalidRecordHeaderValue does not cover the correct scenario - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/22 10:43:00 UTC, 0 replies.
- [PR] MINOR: Add AdminClient stale leader close grace period test [kafka] - posted by "Parkerhiphop (via GitHub)" <gi...@apache.org> on 2026/07/22 11:41:26 UTC, 1 replies.
- [PR] MINOR: Bound decompression memory in ShareGroupDLQRecordFetcher [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/22 11:59:47 UTC, 0 replies.
- [PR] MINOR: bump jline to 3.30.16 [kafka] - posted by "harmadasg (via GitHub)" <gi...@apache.org> on 2026/07/22 12:08:42 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20826) EndToEndLatencyTest#testInvalidRecordHeaderValue does not cover the correct scenario - posted by "majialong (Jira)" <ji...@apache.org> on 2026/07/22 12:14:00 UTC, 0 replies.
- [PR] MINOR: Move SaslClientsWithInvalidCredentialsTest to clients integration tests [kafka] - posted by "Parkerhiphop (via GitHub)" <gi...@apache.org> on 2026/07/22 13:44:22 UTC, 1 replies.
- [jira] [Created] (KAFKA-20827) StreamThread dies with IllegalStateException: Attempted to create an standby task that we already own during a standby/active recycle - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/22 15:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-18157: Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/22 15:04:38 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16158) Cleanup usage of `TimestampedBytesStore` interface - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/22 15:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19629) Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/22 15:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-17535) Flaky testCloseNoWait in KafkaConsumerTest for Classic Consumer - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/22 15:31:00 UTC, 1 replies.
- Re: [PR] KAFKA-20813 Add Podman support to Docker image build tests [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/07/22 15:41:21 UTC, 6 replies.
- [jira] [Created] (KAFKA-20828) shouldClientThrottle() implemented incorrectly for some requests - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2026/07/22 16:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20828) shouldClientThrottle() implemented incorrectly for some requests - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2026/07/22 16:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-19871: Update test with new TopologyTestDriverBuilder [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/22 17:03:06 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20828) shouldClientThrottle() implemented incorrectly for some requests - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/07/22 17:08:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8374) KafkaApis.handleLeaderAndIsrRequest not robust to ZooKeeper exceptions - posted by "Bob Barrett (Jira)" <ji...@apache.org> on 2026/07/22 17:09:00 UTC, 0 replies.
- Re: [PR] MINOR: Set StreamThread to non-daemon status [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/22 17:13:33 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20827) StreamThread dies with IllegalStateException: Attempted to create an standby task that we already own during a standby/active recycle - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/22 17:22:00 UTC, 3 replies.
- [PR] KAFKA-20828: Derive client throttling from response schema [kafka] - posted by "arnabnandy7 (via GitHub)" <gi...@apache.org> on 2026/07/22 17:25:10 UTC, 14 replies.
- [jira] [Updated] (KAFKA-20828) shouldClientThrottle() implemented incorrectly for some requests - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2026/07/22 17:29:00 UTC, 0 replies.
- [PR] KAFKA-20826: Fix EndToEndLatencyTest#testInvalidRecordHeaderValue [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/07/22 17:33:15 UTC, 1 replies.
- [PR] KAFKA-20819: Fail requests when state updater thread dies [kafka] - posted by "arnabnandy7 (via GitHub)" <gi...@apache.org> on 2026/07/22 17:42:57 UTC, 5 replies.
- [PR] KAFKA-20356: make clusterId in-memory thread safe via future [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/07/22 18:44:13 UTC, 1 replies.
- [PR] KAFKA-20828: Return should client throttle true for throttle based responses [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/07/22 21:51:21 UTC, 2 replies.
- Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/07/22 22:31:25 UTC, 6 replies.
- [PR] [4.1] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "tzy-0x7cf (via GitHub)" <gi...@apache.org> on 2026/07/22 22:49:42 UTC, 0 replies.
- [PR] [4.2] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "tzy-0x7cf (via GitHub)" <gi...@apache.org> on 2026/07/22 22:50:44 UTC, 0 replies.
- [PR] [4.3] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "tzy-0x7cf (via GitHub)" <gi...@apache.org> on 2026/07/22 22:51:17 UTC, 0 replies.
- [PR] MINOR:Fix typo in build.gradle and dependencies.gradle [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/22 22:55:11 UTC, 1 replies.
- Re: [PR] KAFKA-20395: Support unregistering controllers [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/07/22 22:57:29 UTC, 35 replies.
- [jira] [Resolved] (KAFKA-20695) Extend "describe group" to return "task offset" metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/22 23:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-20061 `slf4j-api` version upgrade: 1 -->> 2; `log4j-slf4j-impl` artifact renamed to `log4j-slf4j2-impl` [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/23 04:37:17 UTC, 1 replies.
- Re: [PR] Fix authentication bypass in PlainLoginModule JAAS implementation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/23 04:37:19 UTC, 1 replies.
- Re: [PR] KAFKA-10788 : Streamlined the Test cases in CachingInMemoryKeyValueStoreTest [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/23 04:37:21 UTC, 1 replies.
- Re: [PR] KAFKA-12641: RemoteLogMetadataCache: bound leader-epoch state and cache highest copied offset [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/23 04:37:23 UTC, 1 replies.
- Re: [PR] KAFKA-20461: Support -1 (infinite retention) for offsets.retention.minutes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/23 04:37:31 UTC, 1 replies.
- Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka] - posted by "anton-liauchuk (via GitHub)" <gi...@apache.org> on 2026/07/23 07:33:24 UTC, 20 replies.
- Re: [PR] KAFKA-20723: Bound decompression memory in ShareGroupDLQRecordFetcher [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/23 09:02:25 UTC, 4 replies.
- [jira] [Created] (KAFKA-20829) StreamThread floods logs with "Request joining group due to: Shutdown requested" during ▎ SHUTDOWN_APPLICATION under the classic protocol - posted by "Souquières Adam (Jira)" <ji...@apache.org> on 2026/07/23 10:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20829) StreamThread floods logs with "Request joining group due to: Shutdown requested" during ▎ SHUTDOWN_APPLICATION under the classic protocol - posted by "Souquières Adam (Jira)" <ji...@apache.org> on 2026/07/23 10:26:00 UTC, 0 replies.
- [PR] KAFKA-20829: Throttle StreamThread shutdown rebalance enforcement to avoid log flood [kafka] - posted by "SouquieresAdam (via GitHub)" <gi...@apache.org> on 2026/07/23 10:26:30 UTC, 7 replies.
- [jira] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group - posted by "KAI-JAY TU (Jira)" <ji...@apache.org> on 2026/07/23 11:06:00 UTC, 0 replies.
- [PR] KAFKA-19042 Rewrite SaslPlaintextConsumerTest from Scala to Java [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/23 13:12:37 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/23 15:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20793) Mark share.version=2 stable - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/23 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19469) Dead-letter queues for share groups - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/07/23 16:02:00 UTC, 1 replies.
- [PR] KAFKA-20723: Resolve DLQ copy records per produce round. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/23 19:47:52 UTC, 12 replies.
- Re: [PR] KAFKA-20726; Don't reuse the BufferSupplier in kraft state machine [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/07/23 20:33:56 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/23 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/23 21:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-17499) Memory leak when using ReadOnlyKeyValueStore `all()` method - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/24 00:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17869) Tests for clients ensuring KIP-1076 doesn't affect existing metrics - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/24 00:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19292) Introduce soft state for StreamsGroup - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/24 00:39:00 UTC, 0 replies.
- [PR] KAFKA-20790: Add group.streams.assignors broker config + loader [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/24 01:02:01 UTC, 42 replies.
- Re: [PR] KAFKA-20033: make the __remote_log_metadata topic compact [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/24 01:55:08 UTC, 1 replies.
- Re: [PR] MINOR: Improve the CI to avoid running long time tests when only document is changed [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/24 04:36:45 UTC, 0 replies.
- Re: [PR] [KAFKA-19331]: Fix error handling when leader not found in applyLocalFollowersDelta [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/24 04:36:52 UTC, 1 replies.
- [PR] MINOR: Fix formatBytes to return "0 B" for zero bytes [kafka] - posted by "nikolauspschuetz (via GitHub)" <gi...@apache.org> on 2026/07/24 05:23:52 UTC, 1 replies.
- Re: [PR] KAFKA-19871: Add Runtime interface [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/24 06:08:21 UTC, 6 replies.
- [PR] MINOR: Add toString test coverage for Bytes [kafka] - posted by "lsc713 (via GitHub)" <gi...@apache.org> on 2026/07/24 07:17:37 UTC, 0 replies.
- [PR] KAFKA-20665: Promote a warm-up task to active in place in the reconciler [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/24 07:55:51 UTC, 2 replies.
- Re: [PR] KAFKA-20804: Reduce lock contention in ProducerMetadata#add [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2026/07/24 09:40:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/07/24 09:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/24 10:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/24 10:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Yun-Shao Chiang (Jira)" <ji...@apache.org> on 2026/07/24 11:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Yun-Shao Chiang (Jira)" <ji...@apache.org> on 2026/07/24 11:05:00 UTC, 1 replies.
- [PR] MINOR: Remove testImplementation storage:storage-api [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/07/24 11:24:13 UTC, 2 replies.
- [jira] [Created] (KAFKA-20831) Cache SASL KafkaPrincipal for the lifetime of an authenticated connection - posted by "Nandini Singhal (Jira)" <ji...@apache.org> on 2026/07/24 12:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20831) Cache SASL KafkaPrincipal for the lifetime of an authenticated connection - posted by "Nandini Singhal (Jira)" <ji...@apache.org> on 2026/07/24 12:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-19583: fix: enable oauthbearer sasl with native image [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/24 12:54:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20827) StreamThread dies with IllegalStateException: Attempted to create an standby task that we already own during a standby/active recycle - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/24 13:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20832) Cordoned log dirs are not enforced when creating topics/partitions with explicit assignment - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/24 13:43:00 UTC, 0 replies.
- [PR] KAFKA-20827: don't re-create an already-owned task on assignment [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/07/24 13:53:33 UTC, 5 replies.
- [jira] [Created] (KAFKA-20833) API-Contract Annotations for Nullity/Thread Safety - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/07/24 14:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20833) API-Contract Annotations for Nullity/Thread Safety - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/07/24 14:10:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20726) Don't reuse the BufferSupplier in kraft state machine - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/07/24 15:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20726) Don't reuse the BufferSupplier in kraft state machine - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/07/24 15:01:00 UTC, 0 replies.
- [PR] KAFKA-20832: Fix cordon logic with user specified assignments [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/24 15:24:13 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/07/24 15:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20834) Add unit test for Bytes.toString() - posted by "leejuho (Jira)" <ji...@apache.org> on 2026/07/24 16:55:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20834) Add unit test for Bytes.toString() - posted by "leejuho (Jira)" <ji...@apache.org> on 2026/07/24 16:59:00 UTC, 1 replies.
- [PR] Kip1357 config [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/24 18:13:39 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20835) Group-level alter-config RPC fails, if single group config is invalid - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/24 23:23:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20835) Group-level alter-config RPC fails, if single group config is invalid - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/24 23:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20835) Group-level alter-config RPC fails, if single group config is invalid - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/24 23:25:00 UTC, 1 replies.
- Re: [PR] KAFKA-20553: Use ClusterInstance for streams ResetIntegrationTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/24 23:48:39 UTC, 1 replies.
- Re: [PR] KAFKA-20553 Prevent modules from depending on core test output [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/24 23:54:22 UTC, 0 replies.
- [PR] docs: improve README formatting [kafka] - posted by "lian125537 (via GitHub)" <gi...@apache.org> on 2026/07/24 23:54:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20835) Group-level alter-config RPC fails, if single group config is invalid - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/25 00:11:00 UTC, 7 replies.
- [PR] MINOR: Align consumer assignor loading with share and streams [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/25 01:26:28 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20827) StreamThread dies with IllegalStateException: Attempted to create an standby task that we already own during a standby/active recycle - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/07/25 01:39:00 UTC, 0 replies.
- [PR] MINOR: "streams" TaskAssignors must be thread-safe [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/25 03:03:36 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20829) StreamThread floods logs with "Request joining group due to: Shutdown requested" during ▎ SHUTDOWN_APPLICATION under the classic protocol - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/25 03:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [2/2] [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/25 04:05:18 UTC, 4 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/07/25 04:34: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/07/25 04:34:10 UTC, 1 replies.
- [PR] KAFKA-20830: Speed up testFailToStartWhenInternalTopicsAreNotCompacted [kafka] - posted by "hjtiun852 (via GitHub)" <gi...@apache.org> on 2026/07/25 08:22:28 UTC, 1 replies.
- Re: [PR] KAFKA-20831: Cache SASL principal per authentication [kafka] - posted by "nandini12396 (via GitHub)" <gi...@apache.org> on 2026/07/25 10:57:49 UTC, 3 replies.
- Re: [PR] KAFKA-12861: MockProducer NPE with default constructor [kafka] - posted by "dojeee (via GitHub)" <gi...@apache.org> on 2026/07/25 11:18:30 UTC, 0 replies.
- [PR] MINOR: Remove unused LogConfig test helpers [kafka] - posted by "Parkerhiphop (via GitHub)" <gi...@apache.org> on 2026/07/25 15:05:11 UTC, 3 replies.
- [PR] KAFKA-20827: don't re-create an already-owned task on assignment (4.2) [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/07/25 16:32:08 UTC, 0 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/07/25 22:46:05 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-20835) Group-level alter-config RPC fails, if single group config is invalid - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/26 00:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/26 00:48:16 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-20197) Add headers support to StreamPartitioner - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/26 01:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-10730: KafkaApis#handleProduceRequest should use auto-generated protocol [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/26 04:39:48 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/26 05:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20830) speed up testFailToStartWhenInternalTopicsAreNotCompacted - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/26 05:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller - posted by "Haifeng Chen (Jira)" <ji...@apache.org> on 2026/07/26 06:50:00 UTC, 0 replies.
- [PR] Fa kafka 20708 gated kraft controller [kafka] - posted by "1230fahid (via GitHub)" <gi...@apache.org> on 2026/07/26 07:15:10 UTC, 0 replies.
- [PR] KAFKA-20835: Validate only changed group configurations [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 07:23:31 UTC, 5 replies.
- [jira] [Created] (KAFKA-20836) Documentation for header-full StreamPartitioner - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/26 08:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20836) Documentation for header-full StreamPartitioner - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/26 08:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20836) Documentation for header-full StreamPartitioner - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/26 08:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/07/26 08:27:00 UTC, 2 replies.
- [PR] KAFKA-20822: Harden Trogdor polymorphic JSON deserialization [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 09:14:00 UTC, 0 replies.
- [PR] KAFKA-20716: Document unclean leader election transaction limitations [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 09:33:16 UTC, 0 replies.
- [PR] KAFKA-19622: Document KRaft migration operating modes [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 09:38:21 UTC, 0 replies.
- [PR] MINOR: version updates for build and project dependencies [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/07/26 10:06:26 UTC, 0 replies.
- Re: [PR] MINOR: version updates for build and project dependencies (multiple CVEs are addressed) [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/07/26 10:49:00 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-20731) Streams: transitToUpdateStandby is called without checking ACTIVE_RESTORING, crashing the state updater thread - posted by "Arnab Nandy (Jira)" <ji...@apache.org> on 2026/07/26 12:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154) - posted by "Arnab Nandy (Jira)" <ji...@apache.org> on 2026/07/26 12:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group - posted by "Arnab Nandy (Jira)" <ji...@apache.org> on 2026/07/26 12:10:00 UTC, 0 replies.
- [PR] KAFKA-19839: Fix native image zstd compression [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 12:23:29 UTC, 0 replies.
- Re: [PR] KAFKA-20622: Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/26 12:27:36 UTC, 0 replies.
- [PR] KAFKA-20325: Detect SSL listeners for dedicated controllers [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 12:32:59 UTC, 0 replies.
- Re: [PR] MINOR: Scala to Java migration. Migrated some tests from PlaintextAdminIntegrationTest to a new java class. [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/26 12:45:30 UTC, 1 replies.
- [PR] KAFKA-20766: Avoid reverse DNS during SASL authentication [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 13:17:48 UTC, 2 replies.
- [PR] KAFKA-14249: Make TLS idle expiry test deterministic [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 13:38:50 UTC, 2 replies.
- [PR] MINOR: fix StreamPartitioner deprecation warning in ProcessorTopology… [kafka] - posted by "Mirai1129 (via GitHub)" <gi...@apache.org> on 2026/07/26 13:44:07 UTC, 0 replies.
- [jira] [Created] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/26 14:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/26 14:32:00 UTC, 0 replies.
- [PR] KAFKA-20537: Return topic ID for existing topics [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 15:56:06 UTC, 1 replies.
- [PR] KAFKA-18967: Add schema checker evolution tests [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 16:12:20 UTC, 0 replies.
- [PR] KAFKA-18838: Ensure arbitrary memory records are invalid [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 16:43:52 UTC, 0 replies.
- [PR] KAFKA-18970: Enable client module metadata publication [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/07/26 18:08:21 UTC, 0 replies.
- [PR] KAFKA-20410: Make KIP-1191 cluster configs dynamic. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/26 19:14:07 UTC, 1 replies.
- [PR] KAFKA-20809: Add getting started docs for share group DLQ. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/26 19:38:28 UTC, 1 replies.
- [PR] KAFKA-20735: Skip state-directory lock on close when there are no sto… [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/26 20:56:17 UTC, 3 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/07/26 22:53:44 UTC, 0 replies.
- Re: [PR] MINOR: fix StreamPartitioner deprecation warning in ProcessorTopology [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/27 00:18:38 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/27 03:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/07/27 03:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay - posted by "Eric Chang (Jira)" <ji...@apache.org> on 2026/07/27 03:45:00 UTC, 2 replies.
- Re: [PR] KAFKA-16959: ConfigCommand should allow to define both `entity-default` and `entity-name` [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/27 04:44:25 UTC, 0 replies.
- [PR] KAFKA-20838: Reduce IQv2StoreIntegrationTest runtime [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/07/27 04:50:17 UTC, 0 replies.
- [PR] HOTFIX: Remove Time.SYSTEM from ProducerMetadata [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/07/27 05:31:24 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20826) EndToEndLatencyTest#testInvalidRecordHeaderValue does not cover the correct scenario - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/27 05:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20839) KRaft controller stuck at MINIMUM_KRAFT_VERSION after losing leadership race during activation - posted by "kuper (Jira)" <ji...@apache.org> on 2026/07/27 06:15:00 UTC, 0 replies.
- [PR] KAFKA-20839: Fix metadata.version stuck at MINIMUM_KRAFT_VERSION when… [kafka] - posted by "gp1314 (via GitHub)" <gi...@apache.org> on 2026/07/27 06:38:46 UTC, 0 replies.
- [PR] MINOR: add suppress() header-propagation scenario tests [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/27 06:57:30 UTC, 3 replies.
- [jira] [Created] (KAFKA-20840) Bump jetty to 12.0.37 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/27 07:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20840) Bump jetty to 12.0.37 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/27 07:23:00 UTC, 0 replies.
- [PR] KAFKA-20840: Bump jetty to 12.0.37 [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/27 07:32:23 UTC, 2 replies.
- [jira] [Updated] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/27 08:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/27 08:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-20809: Updated getting started docs with share group DLQ. [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/27 08:50:58 UTC, 2 replies.
- Re: [PR] KAFKA-20738: Producer 2PC InitProducerId request must negotiate v6 [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/27 08:58:54 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19686) Trigger Docker image builds in release script - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/27 09:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20841) CoordinatorLoaderImpl can read past bounded FileRecords slices with preallocated logs, causing CorruptRecordException and FAILED group-coordinator shards - posted by "Leonard Solvik Lisoey (Jira)" <ji...@apache.org> on 2026/07/27 10:21:00 UTC, 0 replies.
- [PR] KAFKA-20501: Add IQv1 isolation-level integration tests [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/27 10:54:32 UTC, 1 replies.
- [jira] [Updated] (KAFKA-19469) Dead-letter queues for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/27 11:45:00 UTC, 0 replies.
- [PR] KAFKA-20503: Add integration tests for transaction buffering [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/27 11:48:13 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19469) Dead-letter queues for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/27 11:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20809) Update documentation with KIP-1191 information - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/27 11:56:00 UTC, 0 replies.
- [PR] KAFKA-20504: Update state wipe tests [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/07/27 12:09:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics - posted by "RITIK KUMAR JAISWAL (Jira)" <ji...@apache.org> on 2026/07/27 12:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20832) Cordoned log dirs are not enforced when creating topics/partitions with explicit assignment - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/27 12:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20840) Bump jetty to 12.0.37 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/27 12:39:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix StreamPartitioner deprecation warning in ProcessorTopology [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/27 12:56:02 UTC, 0 replies.
- [PR] MINOR: Rewrite testListTopicsWithOptionListInternal [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/27 13:34:08 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/07/27 13:38:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/07/27 14:09:00 UTC, 0 replies.
- [PR] KAFKA-20413: Add headers-aware RocksDB list-value store [1/2] [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/27 14:50:25 UTC, 0 replies.
- [jira] [Created] (KAFKA-20842) Bump lz4 to 1.11.1 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/27 14:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20842) Bump lz4 to 1.11.1 - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/27 14:51:00 UTC, 0 replies.
- [PR] KAFKA-20842: Bump lz4 to 1.11.1 [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/27 15:03:06 UTC, 5 replies.
- [PR] KAFKA-20841: Bound the coordinator load buffer to the FileRecords slice [kafka] - posted by "asdf2014 (via GitHub)" <gi...@apache.org> on 2026/07/27 15:42:10 UTC, 0 replies.
- [PR] KAFKA-20253: Backport heartbeat CPU spin fixes (4.3) [kafka] - posted by "ChoMinGi (via GitHub)" <gi...@apache.org> on 2026/07/27 16:16:06 UTC, 1 replies.
- [PR] KAFKA-20253: Backport heartbeat CPU spin fixes (4.2) [kafka] - posted by "ChoMinGi (via GitHub)" <gi...@apache.org> on 2026/07/27 16:16:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20828) shouldClientThrottle() implemented incorrectly for some requests - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2026/07/27 17:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-20413: Add missing headers-aware ListValueStore for streams-streams join [1/2] [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/27 18:49:49 UTC, 0 replies.
- [jira] [Created] (KAFKA-20843) Custom consumer group assignors may silently use duplicate or built-in assignor names - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 18:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20843) Custom consumer group assignors may silently use duplicate or built-in assignor names - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 18:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20843) Custom consumer group assignors may silently use duplicate or built-in assignor names - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 18:56:00 UTC, 3 replies.
- [PR] KAFKA-20413: Make the stream-stream outer join use the headers-aware ListValueStore [2/3] [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/27 19:00:13 UTC, 0 replies.
- [PR] KAFKA-20413: Add list-value store format and headers round-trip tests [3/3] [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/27 19:00:32 UTC, 0 replies.
- [PR] MINOR: deflake AdminMetadataTest [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/07/27 19:05:01 UTC, 5 replies.
- [jira] [Created] (KAFKA-20844) Improve inflightPoll lifecycle handling in the async Consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/27 19:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20845) Consumer group downgrades can leave group in invalid state when classic group metadata is very large - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/07/27 20:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20845) Consumer group downgrades can leave group in invalid state when classic group metadata is very large - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/07/27 20:33:00 UTC, 1 replies.
- [PR] KAFKA-20845: Don't flush empty batch when appending large records in group coordinator [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/07/27 21:13:58 UTC, 5 replies.
- [jira] [Created] (KAFKA-20846) Streams TaskAssignor receives mutable nested collections in its GroupSpec - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 21:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20846) Streams TaskAssignor receives mutable nested collections in its GroupSpec - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 21:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20846) Streams TaskAssignor receives mutable nested collections in its GroupSpec - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/27 22:47:00 UTC, 2 replies.
- [PR] KAFKA-20846：Make the streams assignor GroupSpec deeply unmodifiable [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/27 22:48:47 UTC, 8 replies.
- [jira] [Created] (KAFKA-20847) Suppress buffer changelog tombstones carry no record metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/27 23:30:00 UTC, 0 replies.
- [PR] MINOR: bind only on loopback in SelectorTest/SslSelectorTest [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/07/28 01:04:14 UTC, 0 replies.
- Re: [PR] KAFKA-19919: Avoid reverse DNS for built-in SASL servers [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:07:21 UTC, 0 replies.
- Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:34:00 UTC, 1 replies.
- Re: [PR] KAFKA-19486: use the latest version of kafka-topics.sh to create topics in system tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:34:03 UTC, 1 replies.
- Re: [PR] KAFKA-9651: Handle edge case when partition metadata contains zero partitions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:34:09 UTC, 0 replies.
- Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:34:13 UTC, 1 replies.
- Re: [PR] KAFKA-19307: Add file-based config and CLI credentials support to OAuthCompatibilityTool [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/28 04:34:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-20848) Consider to surface group-level misconfigurations client side - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/28 05:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20848) Consider to surface group-level misconfigurations client side - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/28 05:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20779) followup review on the merged KIP-1265 PR - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2026/07/28 07:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-20413: Add headers-aware RocksDB list-value store and keep its changelog PLAIN [1/3] [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/28 08:30:11 UTC, 6 replies.
- [jira] [Commented] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/28 08:46:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/07/28 08:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20842) Bump lz4 to 1.11.1 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/28 10:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20849) Allow enabling header support on suppress() per operator, and update the headers-aware store docs - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/28 10:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20849) Update the headers-aware store docs on Suppress() - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/28 10:30:00 UTC, 0 replies.
- [PR] Fix blog post link in uses.md [kafka] - posted by "errwnd (via GitHub)" <gi...@apache.org> on 2026/07/28 11:47:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-20850) Add system test coverage for suppress() changelog upgrade/downgrade with dsl.store.format=HEADERS - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/07/28 12:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20851) Spotless gradle plugin: version update (8.4.0 -->> 8.9.0) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/28 12:41:00 UTC, 0 replies.
- [PR] KAFKA-20851 spotless gradle plugin version update: 8.4.0 -->> 8.9.0 [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/07/28 12:56:57 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20852) buffer + doc PR - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/28 13:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20706) Implement query type 4 (TimestampedWindowRangeWithHeadersQuery) - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/28 13:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20852) buffer + doc PR - posted by "Jess Jin (Jira)" <ji...@apache.org> on 2026/07/28 13:09:00 UTC, 0 replies.
- [PR] MINOR: Fix Javadoc code sample in KafkaShareConsumer [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/28 13:31:15 UTC, 1 replies.
- [PR] MINOR: De-duplicate Metered*WithHeaders read-only-record iterators [kafka] - posted by "Jess668 (via GitHub)" <gi...@apache.org> on 2026/07/28 13:52:26 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/07/28 14:03:00 UTC, 0 replies.
- [PR] MINOR: Update MiniKdc class path in minikdc.py [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/07/28 14:28:30 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20842) Bump lz4 to 1.11.1 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/28 15:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20853) `-PmavenUrl=file:` does not work due to unsupported Authentication - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/28 15:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20853) `-PmavenUrl=file:` does not work due to unsupported Authentication - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/28 15:16:00 UTC, 1 replies.
- [PR] KAFKA-18628: Deprecate broker.id config (KIP-1232) [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/07/28 15:55:27 UTC, 14 replies.
- [PR] MINOR: Complete nodeApiVersions future when describeFeatures fails [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/07/28 16:37:49 UTC, 1 replies.
- Re: [PR] MINOR: Cleanups following KAFKA-20637 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/28 16:44:15 UTC, 3 replies.
- [PR] KAFKA-20780: Fix to clear completed inflight poll on empty fetch response and time left [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/28 16:55:09 UTC, 2 replies.
- Re: [PR] MINOR: Merge kafka.security classes into test-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/28 17:04:19 UTC, 1 replies.
- Re: [PR] MINOR: Fix blog post link in uses.md [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/28 18:53:16 UTC, 0 replies.
- [PR] KAFKA-20792: Fix invalid partition -1 in FK join triggered by punctuator [kafka] - posted by "siddharthaDevineni (via GitHub)" <gi...@apache.org> on 2026/07/28 21:26:06 UTC, 0 replies.
- Re: [PR] KAFKA-20278 : Refactor - Consolidate process-and-verify helpers, PART-2 [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/28 21:32:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1 - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/07/28 21:49:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1 - posted by "Siddhartha Devineni (Jira)" <ji...@apache.org> on 2026/07/28 21:50:00 UTC, 1 replies.
- [PR] KAFKA-20665: Change task roles in place in the reconciler [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/28 23:13:14 UTC, 1 replies.
- Re: [PR] KAFKA-20278 : Refactor - Consolidate process-and-verify helpers, [2/N] [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/28 23:26:24 UTC, 11 replies.
- [PR] KAFKA-20843: Custom consumer group assignors may silently use duplicate or built-in assignor names [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/29 01:14:31 UTC, 2 replies.
- [PR] KAFKA-20847: Carry record metadata on suppress buffer changelog tombstones [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/07/29 01:28:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-20854) A more obvious busy loop due to KIP-909 - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/29 01:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20855) Refactor NetworkClient - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/29 01:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20855) Refactor NetworkClient - posted by "Cheng Yi Chang (Jira)" <ji...@apache.org> on 2026/07/29 01:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20430) Add configuration to control internal topic creation in Kafka Connect - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/29 03:05:00 UTC, 0 replies.
- Re: [PR] KAFKA-20455: Wait for all producers to send startup_complete before executing system test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/07/29 04:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20856) Allow to enable/disable headers support on `suppress()` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/29 05:51:00 UTC, 0 replies.
- [PR] KAFKA-20430 Fix getTopicConfig() for connector-specific offset stores [kafka] - posted by "kaijaytu (via GitHub)" <gi...@apache.org> on 2026/07/29 08:09:20 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-17840) Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/29 09:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-19298: Move RuntimeLoggerManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/29 09:12:27 UTC, 2 replies.
- [jira] [Created] (KAFKA-20857) Use Java 25 in Docker Images - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2026/07/29 09:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20857) Use Java 25 in Docker Images - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2026/07/29 09:14:00 UTC, 0 replies.
- [PR] KAFKA-20665: Refine the assignment refiner scaffolding [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/29 09:19:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/29 09:27:00 UTC, 0 replies.
- Re: [PR] KAFKA-20328 : [1/N] headers-aware api test coverage [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/29 09:29:09 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20854) A more obvious busy loop due to KIP-909 - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/07/29 09:37:00 UTC, 0 replies.
- [PR] MINOR: Fix duplicated closing brace in {@link} Javadoc tags in admin Result classes [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/07/29 10:36:10 UTC, 0 replies.
- [PR] MINOR: allow running docker tests with kafka-archive [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/07/29 11:22:58 UTC, 0 replies.
- [PR] MINOR: Move RequestConvertToJsonTest to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/29 12:40:28 UTC, 0 replies.
- Re: [PR] MINOR: Fix duplicated closing brace in `{@link}` Javadoc tags in admin Result classes [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/07/29 13:57:49 UTC, 0 replies.
- [PR] KAFKA-20828: Centralize client throttling version logic [kafka] - posted by "arnabnandy7 (via GitHub)" <gi...@apache.org> on 2026/07/29 14:10:18 UTC, 5 replies.
- Re: [PR] MINOR: Clean up LogConfig defaults and unused helper [kafka] - posted by "Parkerhiphop (via GitHub)" <gi...@apache.org> on 2026/07/29 14:16:26 UTC, 1 replies.
- [jira] [Created] (KAFKA-20858) Refactor SubscriptionState to give cleaner separation for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/29 15:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20858) Refactor SubscriptionState to give cleaner separation for share groups - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/29 15:28:00 UTC, 0 replies.
- [PR] MINOR: ensure ps output is unlimited width [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/07/29 15:36:07 UTC, 1 replies.
- [PR] MINOR: improve "streams" default rebalance listener [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/29 18:05:43 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20843) Custom consumer group assignors may silently use duplicate or built-in assignor names - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/07/29 18:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20859) Reduce per-append record sizing cost in the producer incremental strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/29 19:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/07/29 20:01:00 UTC, 0 replies.
- [PR] KAFKA-20328: [2/N] headers-aware decorator/forwarder test coverage [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/07/29 20:45:15 UTC, 1 replies.
- [jira] [Assigned] (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 "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/29 23:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-20834: Add toString test coverage for Bytes [kafka] - posted by "lsc713 (via GitHub)" <gi...@apache.org> on 2026/07/30 00:59:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20854) A more obvious busy loop due to KIP-909 - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/07/30 01:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20860) Broken error handling in the async consumer background thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 01:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20860) Broken error handling in the async consumer background thread - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 01:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20861) Kafka Streams should handle corrupted assignment pro-actively - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 01:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20861) Kafka Streams should handle corrupted assignment pro-actively - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 01:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20860) Broken error handling in the async consumer background thread - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/07/30 02:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20790) Promote streams assignor API to public module - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 04:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20683) Add broker side custom assignors for "streams" groups - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/30 05:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20736) Improve leadership change handling in ShareConsumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/07/30 06:58:00 UTC, 0 replies.
- [PR] MINOR: Fix StreamPartitioner removal warnings in integration tests [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/30 07:15:00 UTC, 0 replies.
- [PR] MINOR: Make fenced state error message generic [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/30 09:26:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20862) Update gradle versions plugin in order to resolve issues with dependencies resolution - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/30 09:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20862) Update gradle versions plugin in order to resolve issues with dependencies resolution - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/30 09:43:00 UTC, 2 replies.
- [PR] KAFKA-20862 update gradle versions plugin (0.56.0 -->> 0.57.0) in order to resolve issues with dependencies resolution [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/07/30 10:05:32 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19298) Move RuntimeLoggerManager to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/30 10:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20862) Update gradle versions plugin in order to resolve corner case issues with dependencies resolution - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/30 10:15:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/30 10:20:00 UTC, 0 replies.
- Re: [PR] MINOR: Add generic fenced state error message [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/30 10:30:13 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/30 11:00:00 UTC, 0 replies.
- [PR] KAFKA-20858: Refactor subscription state [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/07/30 13:46:47 UTC, 0 replies.
- [PR] [WIP]: Adding benchmark for producer append [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/30 16:39:10 UTC, 0 replies.
- [jira] [Created] (KAFKA-20863) Add producer accumulator append benchmark - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/30 18:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20864) Fix to avoid potential early batch close on pool exhausted if race happens - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/30 20:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20865) Add check so voters cannot be unregistered - posted by "Kevin Wu (Jira)" <ji...@apache.org> on 2026/07/30 20:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20866) Remove incremental-only fields from RecordAppendResult - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/07/30 20:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to 10.10.1 - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/30 20:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20867) Upgrade RocksDB dependency from 10.1.3 to 10.10.1 - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/07/30 20:25:00 UTC, 0 replies.
- [PR] [DO NOT MERGE]KAFKA-20867: Upgrade RocksDB dependency from 10.1.3 to 10.10.1 [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/07/30 20:28:26 UTC, 0 replies.
- Re: [PR] KAFKA-20782: Fix lost IQ metadata in "streams" protocol [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/31 00:58:55 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20868) Add warmup tasks to IQ metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 01:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20868) Consider to add warmup tasks to IQ metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 01:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20868) Add warmup tasks to IQ metadata - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 01:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20869) KafkaStreams#addStreamsThread crashed global-task-only client - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 02:39:00 UTC, 0 replies.
- [PR] KAFKA-20861: Kafka Streams should handle corrupted assignments pro-actively [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/31 02:58:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-20870) Fix owned-task reports in StreamsGroupHeartbeat - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 05:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20870) Fix owned-task reports in StreamsGroupHeartbeat - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 05:17:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20870) Fix owned-task reports in StreamsGroupHeartbeat - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/07/31 05:17:00 UTC, 2 replies.
- [PR] MINOR: Directly instantiate persister instead of loading class. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/07/31 05:18:43 UTC, 2 replies.
- [PR] MINOR: Avoid reflective class loading for share state persister [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/31 06:09:04 UTC, 1 replies.
- [PR] KAFKA-20870: Add test for the owned-task report for a single-role assignment change [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/31 06:25:14 UTC, 0 replies.
- Re: [PR] MINOR: Remove accidental unnecessary code in src [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/07/31 07:28:17 UTC, 0 replies.
- [PR] MINOR: Remove EnrichedSourceConnectorConfig [kafka] - posted by "dino2895 (via GitHub)" <gi...@apache.org> on 2026/07/31 08:28:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20862) Update gradle versions plugin in order to resolve corner case issues with dependencies resolution - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/31 10:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-20862 update gradle-versions-plugin to improve `dependencyUpdates` task result output [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/07/31 12:31:54 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20862) Update gradle-versions-plugin to improve `dependencyUpdates` task result output - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/07/31 12:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20871) Upgrade Jetty 12.0.34 dependencies in Kafka to address multiple security vulnerabilities - posted by "Mangesh Dushman (Jira)" <ji...@apache.org> on 2026/07/31 13:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20871) Upgrade Jetty 12.0.34 dependencies in Kafka to address multiple security vulnerabilities - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/07/31 14:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20871) Upgrade Jetty 12.0.34 dependencies in Kafka to address multiple security vulnerabilities - posted by "Mangesh Dushman (Jira)" <ji...@apache.org> on 2026/07/31 14:12:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-20872) Integrate api-checker module into CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/31 14:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20872) Integrate api-checker module into CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/31 14:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20872) Integrate api-checker module into CI - posted by "dino2895 (Jira)" <ji...@apache.org> on 2026/07/31 14:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20779) followup review on the merged KIP-1265 PR - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/07/31 14:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20873) KafkaStreams.removeStreamThread can deadlock with a concurrent REPLACE_THREAD uncaught-exception handler - posted by "TengYao Chi (Jira)" <ji...@apache.org> on 2026/07/31 15:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20874) SslFactory not closed after extracting SSLSocketFactory - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/31 15:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20874) RESOURCE_LEAK: SslFactory not closed after extracting SSLSocketFactory - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/07/31 15:47:00 UTC, 0 replies.
- [PR] KAFKA-20873: Fix deadlock between removeStreamThread and addStreamThread [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/07/31 15:47:32 UTC, 0 replies.
- [PR] KAFKA-20874: Close SslFactory in JaasOptionsUtils.createSSLSocketFactory() [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2026/07/31 16:10:29 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20873) KafkaStreams.removeStreamThread can deadlock with a concurrent REPLACE_THREAD uncaught-exception handler - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 17:49:00 UTC, 0 replies.
- [PR] KAFKA-20868: Add warmup tasks to IQ metadata [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/07/31 19:32:38 UTC, 0 replies.
- [PR] KAFKA-20849: Update the headers-aware store docs on suppress() [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/07/31 19:49:07 UTC, 1 replies.
- [jira] [Created] (KAFKA-20875) Headers store adapters bypass the `WrappedStateStore` chain - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/31 19:54:00 UTC, 0 replies.
- [PR] KAFKA-20864: Fix to avoid early batch close if extension fails [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/07/31 19:57:44 UTC, 0 replies.
- [jira] [Created] (KAFKA-20876) Windowed restore optimisation gives up when `endOffset-1` is a transaction control record - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/31 20:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20875) Headers store adapters bypass the `WrappedStateStore` chain - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/31 20:27:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20876) Windowed restore optimisation gives up when `endOffset-1` is a transaction control record - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/07/31 20:28:04 UTC, 1 replies.
- [jira] [Created] (KAFKA-20877) Streams task-level restore-rate and update-rate incorrect - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 22:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20877) Streams task-level restore-rate and update-rate incorrect - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/07/31 22:14:00 UTC, 0 replies.
- [PR] KAFKA-20877: Fix incorrect restore-rate and update-rate metrics [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/07/31 22:17:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20878) UnsupportedOperationException: This task is read-only during unclean shutdown - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/31 22:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20878) UnsupportedOperationException: This task is read-only during unclean shutdown - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/07/31 22:36:00 UTC, 0 replies.
- [PR] KAFKA-20878: Fixed task closing during task manager shutdown if the state updater thread is dead. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/07/31 22:50:45 UTC, 0 replies.