You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [PR] KAFKA-20329: Test headers dsl.store.format further (2/N) [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/05/01 00:20:41 UTC, 0 replies.
- Re: [PR] KAFKA-20496: Add isolation level to IQ dispatch [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/01 01:06:02 UTC, 6 replies.
- Re: [PR] KAFKA-20362: Auto-fill PR reviewers in PR description [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/05/01 03:20:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20527) org.apache.kafka.clients.consumer.KafkaConsumerTest bug fixes for group rebalance protocol - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/01 04:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-20523: Fix logger class name in KStreamKTableJoinProcessor [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:28:52 UTC, 3 replies.
- Re: [PR] MINOR: Add toString() to KafkaMetric for readable logging [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:28:54 UTC, 16 replies.
- Re: [PR] MINOR: Fix Log4j configuration file path in kafka-run-class.bat [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:29:29 UTC, 1 replies.
- Re: [PR] [KAFKA-20032] KIP-1265 Automatic detection of internal API usage [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:29:31 UTC, 1 replies.
- Re: [PR] MINOR:Extract public code [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:30:01 UTC, 0 replies.
- Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:30:26 UTC, 0 replies.
- Re: [PR] Revert "MINOR: Cleanup metadata module" [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:47:16 UTC, 1 replies.
- Re: [PR] KAFKA-19685: Add possibility of passing in revoked partitions in task precommit [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/01 04:47:20 UTC, 1 replies.
- [jira] [Updated] (KAFKA-10369) Add deduplicate operation in KStream - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2026/05/01 08:09:00 UTC, 2 replies.
- Re: [PR] MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to AbstractKafkaConfig [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/01 08:18:59 UTC, 3 replies.
- [PR] KAFKA-10369: Add deduplication operator to Streams DSL (KIP-655) [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2026/05/01 08:53:05 UTC, 2 replies.
- Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 09:40:22 UTC, 1 replies.
- Re: [PR] KAFKA-19381: add ConfigDef.ConfigKey.Builder [kafka] - posted by "Claudenw (via GitHub)" <gi...@apache.org> on 2026/05/01 10:25:25 UTC, 0 replies.
- [PR] Kafka 19381 add config key builder [kafka] - posted by "Claudenw (via GitHub)" <gi...@apache.org> on 2026/05/01 10:28:36 UTC, 0 replies.
- Re: [PR] MINOR: Optimize `describeConfigs` queries and address cleanups for `ConfigCommand` [kafka] - posted by "Rancho-7 (via GitHub)" <gi...@apache.org> on 2026/05/01 11:39:13 UTC, 6 replies.
- Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2026/05/01 12:15:01 UTC, 15 replies.
- [jira] [Commented] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/01 13:07:00 UTC, 1 replies.
- Re: [PR] KAFKA-20522: Refine test coverage for consumer close-on-interrupt best-effort behavior. [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/05/01 13:36:09 UTC, 6 replies.
- Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/05/01 13:53:56 UTC, 0 replies.
- Re: [PR] KAFKA-20489: Add enable.transactional.statestores [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/01 14:19:44 UTC, 3 replies.
- Re: [PR] KAFKA-20492: Prepare DBAccessor for txn support [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/01 14:20:05 UTC, 5 replies.
- Re: [PR] MINOR: Migrate ProduceRequestTest to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 14:22:00 UTC, 1 replies.
- Re: [PR] MINOR: Cleanup TestUtils.scala [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 14:33:58 UTC, 5 replies.
- Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/05/01 16:36:27 UTC, 3 replies.
- [PR] KAFKA-20395: Support unregistering controllers [kafka] - posted by "kevin-wu24 (via GitHub)" <gi...@apache.org> on 2026/05/01 17:48:01 UTC, 20 replies.
- Re: [PR] MINOR: Fix various typos and formatting issues across multiple modules [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 18:26:54 UTC, 5 replies.
- Re: [PR] MINOR: Add docs for KIP-1035 [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/01 18:56:32 UTC, 2 replies.
- Re: [PR] KAFKA-20297 Move SecurityUtils, ConfigUtils, LogContext, AppInfoParser into internal [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 18:57:55 UTC, 1 replies.
- Re: [PR] KAFKA-20435: Move LogManagerTest to storage module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 19:14:11 UTC, 4 replies.
- Re: [PR] KAFKA-19193 Support rack-aware partitioning for Kafka producer [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2026/05/01 20:58:39 UTC, 3 replies.
- [PR] MINOR: Switched RecordAccumulator.append from ByteBuffer to ByteBufferOutputStream. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/01 22:36:18 UTC, 2 replies.
- Re: [PR] KAFKA-13022: Optimize ClientQuotasImage#describe [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 22:45:29 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-13022) Optimize ClientQuotasImage#describe - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/01 22:46:00 UTC, 0 replies.
- Re: [PR] MINOR: Optimize ClientQuotasImage lookup (KAFKA-13022) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 22:46:15 UTC, 1 replies.
- Re: [PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (2/N) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/01 23:09:46 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/01 23:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19700) Fix flaky DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/01 23:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/01 23:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-19700 : remove flaky testDescribeStreamsGroupWithShortTimeout test [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/01 23:14:28 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19700) Fix flaky DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/01 23:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/01 23:27:52 UTC, 11 replies.
- [jira] [Commented] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/05/01 23:54:00 UTC, 0 replies.
- Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/05/02 02:14:33 UTC, 4 replies.
- Re: [PR] KAFKA-20357: Persist lastProducerEpoch fields for the transaction log. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 04:10:51 UTC, 4 replies.
- Re: [PR] KAFKA-20087: Automate Docker Images creation workflow [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 04:11:22 UTC, 0 replies.
- Re: [PR] Add producer metrics for adaptive partitioning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 04:11:28 UTC, 0 replies.
- Re: [PR] MINOR: improve error message on TLS certificate validation failure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 04:11:44 UTC, 0 replies.
- Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/02 04:12:15 UTC, 0 replies.
- Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/02 06:56:04 UTC, 3 replies.
- Re: [PR] KAFKA-17251: Avoid WARN on cleanup when state directory only contains process metadata. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/02 07:09:26 UTC, 0 replies.
- [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2026/05/02 08:53:41 UTC, 15 replies.
- [jira] [Updated] (KAFKA-20082) Hide record implementation from user - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/05/02 09:04:00 UTC, 0 replies.
- [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] - posted by "dejan2609 (via GitHub)" <gi...@apache.org> on 2026/05/02 11:44:29 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project) - posted by "Dejan Stojadinović (Jira)" <ji...@apache.org> on 2026/05/02 12:19: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/05/02 13:27:56 UTC, 4 replies.
- Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/02 14:22:19 UTC, 0 replies.
- Re: [PR] KAFKA-20335: Document KIP-1271 headers-aware state stores [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/02 15:31:56 UTC, 23 replies.
- [jira] [Commented] (KAFKA-20429) Review async consumer single background queue design - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/02 16:10:00 UTC, 1 replies.
- Re: [PR] KAFKA-20044 : server - Fix timeout ReconfigurableQuorumIntegrationTest.java [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/02 16:42:20 UTC, 2 replies.
- [PR] MINOR: Add tests for RaftVoterEndpoint [kafka] - posted by "kuoche1712003 (via GitHub)" <gi...@apache.org> on 2026/05/02 17:29:28 UTC, 3 replies.
- [jira] [Created] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/02 18:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/02 18:14:00 UTC, 1 replies.
- Re: [PR] KAFKA-20389: Filter internal keys from connector plugin config REST response [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/02 19:43:33 UTC, 12 replies.
- [PR] KAFKA-20328 : Headers-aware api test coverage [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/02 19:54:45 UTC, 0 replies.
- Re: [PR] KAFKA-20328 : streams - Adding missing test files - streams headers [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/02 19:59:16 UTC, 1 replies.
- Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/02 20:31:57 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/02 20:36:00 UTC, 0 replies.
- Re: [PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/02 20:40:07 UTC, 1 replies.
- Re: [PR] MINOR: Rewrite DefaultApiVersionManagerTest from Scala to Java and move it to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/02 20:54:24 UTC, 2 replies.
- Re: [PR] KAFKA-18309: Change log.segment.bytes config type from INT to LONG [kafka] - posted by "acgtun (via GitHub)" <gi...@apache.org> on 2026/05/02 20:58:34 UTC, 1 replies.
- [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/05/02 21:53:45 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/02 22:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20545) Flaky tests in MirrorConnectorsIntegrationSSLTest - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/02 23:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19866) Support transactional producer in console producer - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/03 04:13:00 UTC, 0 replies.
- Re: [PR] Enhanced mm2 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/03 04:23:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/05/03 09:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2026/05/03 09:17:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists - posted by "Jiayao Sun (Jira)" <ji...@apache.org> on 2026/05/03 10:12:00 UTC, 0 replies.
- [PR] Caching immutable voterKeys [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2026/05/03 12:54:50 UTC, 2 replies.
- [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/03 13:08:09 UTC, 8 replies.
- [PR] MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments [kafka] - posted by "kuoche1712003 (via GitHub)" <gi...@apache.org> on 2026/05/03 15:44:08 UTC, 3 replies.
- Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka] - posted by "mirkoalicastro (via GitHub)" <gi...@apache.org> on 2026/05/03 17:29:16 UTC, 13 replies.
- [jira] [Created] (KAFKA-20548) Client instance ID in all request headers - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/03 21:16:00 UTC, 0 replies.
- Re: [PR] KAFKA-14485: Move LogCleaner to storage module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/03 23:07:25 UTC, 1 replies.
- Re: [PR] MINOR: Move LogOffsetTest to server module and rewrite in Java [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/03 23:20:46 UTC, 9 replies.
- Re: [PR] KAFKA-19042 Rewrite TransactionsTest from Scala to Java [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/04 00:30:27 UTC, 5 replies.
- [PR] MINOR: Move TestSslUtils to client test fixtures [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2026/05/04 01:48:42 UTC, 4 replies.
- [PR] KAFKA-17164: Enforce 'application.server' : format at config level. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/04 04:10:18 UTC, 12 replies.
- [jira] [Commented] (KAFKA-17164) Consider to enforce application.server : format at config level - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/04 04:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20071) Fix flaky ProducerIdManagerTest#testRetryBackoff... - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/04 04:37:00 UTC, 0 replies.
- [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/05/04 04:43:35 UTC, 8 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - ServerAndProtocol (3/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 04:45:01 UTC, 1 replies.
- Re: [PR] KAFKA-19925: Fix transaction timeout handling during broker upgrades [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 04:45:03 UTC, 1 replies.
- Re: [PR] Invoke OffsetCommitCallback immediately on commit failure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/04 04:45:07 UTC, 1 replies.
- Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/04 04:56:02 UTC, 2 replies.
- [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/04 05:38:36 UTC, 15 replies.
- [jira] [Resolved] (KAFKA-20415) Dynamic config for enabling dlq - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/04 06:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20410) Add DLQ configuration parameters as defined in the KIP - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/04 06:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20549) Implementation of Share Group DLQ Manager - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/04 06:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/04 06:32:56 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment() - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/05/04 07:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/04 07:53:33 UTC, 11 replies.
- Re: [PR] KAFKA-19782: Improve perfomance Authorizer.authorizeByResourceType by using Prefix Trie [kafka] - posted by "ekuvardin (via GitHub)" <gi...@apache.org> on 2026/05/04 08:09:28 UTC, 0 replies.
- Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2026/05/04 08:44:48 UTC, 148 replies.
- [jira] [Assigned] (KAFKA-20223) Extended I/O Metrics Collection - posted by "Sahil Devgon (Jira)" <ji...@apache.org> on 2026/05/04 08:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20170) Support topology updates for streams groups without requiring a new group - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/04 09:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/04 09:49:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/04 10:08:00 UTC, 0 replies.
- Re: [PR] KAFKA-19009: Move MetadataCacheTest to metadata module [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/04 10:08:45 UTC, 3 replies.
- Re: [PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/04 11:54:48 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/04 12:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-20292 [2/N]: Handle membership changes during offloaded streams assignments [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/05/04 12:30:29 UTC, 6 replies.
- Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Server Side. [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/05/04 12:36:58 UTC, 9 replies.
- Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2026/05/04 12:50:21 UTC, 1 replies.
- [jira] [Commented] (KAFKA-18389) Do not lose votedKey on transition to LeaderState - posted by "Yunseop Eom (Jira)" <ji...@apache.org> on 2026/05/04 12:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20541) Duplicate generated folder in kafka-site - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/05/04 13:28:00 UTC, 5 replies.
- Re: [PR] KAFKA-20456: Track timed-out waitForFuture() futures and clean up leaked tasks [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/04 14:52:07 UTC, 0 replies.
- Re: [PR] KAFKA-20456: Bound waitForFuture() timeout to less than max.poll.interval [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/04 14:52:27 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20441) Follow ups for KIP-1066 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/04 15:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false - posted by "Pavel Cermak (Jira)" <ji...@apache.org> on 2026/05/04 16:45:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-13499) Avoid restoring outdated records - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/05/04 17:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "RITIK KUMAR JAISWAL (Jira)" <ji...@apache.org> on 2026/05/04 17:42:00 UTC, 1 replies.
- Re: [PR] KAFKA-20380: controller.quorum.voters should act as advertised.listeners if the latter is not defined [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/04 17:53:11 UTC, 1 replies.
- [PR] KAFKA-20444: [1/N] Add TxnOffsetCommit v6 schema (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/04 18:42:54 UTC, 1 replies.
- Re: [PR] KAFKA-20245: DLQ records exceeding max delivery count. [3/N] [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/04 18:58:04 UTC, 8 replies.
- [jira] [Commented] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch - posted by "David Arthur (Jira)" <ji...@apache.org> on 2026/05/04 19:07:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-14192) Move registering and unregistering changelogs to state updater - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/04 22:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14192) Move registering and unregistering changelogs to state updater - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/04 22:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17789) State updater stuck when starting with empty state folder - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/04 23:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/05 02:00:00 UTC, 0 replies.
- [PR] KAFKA-20546: Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest [kafka] - posted by "YutaLin (via GitHub)" <gi...@apache.org> on 2026/05/05 03:49:23 UTC, 1 replies.
- Re: [PR] KAFKA-20528: Verify LZ4 frame content checksum on the read path [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 04:08:26 UTC, 0 replies.
- Re: [PR] KAFKA-20462: Preserve original source-record headers in ErrorHandlerContext [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 04:08:28 UTC, 1 replies.
- Re: [PR] KAFKA-20336: Add documentation DSL headers-aware state stores [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/05 04:24:02 UTC, 13 replies.
- [jira] [Commented] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol - posted by "Himanshu Pandey (Jira)" <ji...@apache.org> on 2026/05/05 04:26:00 UTC, 0 replies.
- Re: [PR] KAFKA-2526: command line --producer-property wins [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 04:33:29 UTC, 1 replies.
- Re: [PR] KAFKA-7138: Add DLQ name and replication factor to Connect configuration [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/05 04:33:35 UTC, 1 replies.
- [PR] KAFKA-20550: Rename OffsetsUtils to GroupOffsetsResetter [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/05 05:13:25 UTC, 2 replies.
- Re: [PR] MINOR: refactor AbstractSegmentsTests to reduce redundancies [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/05 05:52:16 UTC, 1 replies.
- [PR] MINOR: Fix misleading log message when lastOffset < firstOffset in SharePartition [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/05 06:21:12 UTC, 1 replies.
- Re: [PR] KAFKA-18563: move RaftClientTestContext RpcVersion methods into RaftProtocol [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/05 06:46:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20335) Update docs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 07:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20335) Update docs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 07:55:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20336) Update docs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 07:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20336) Update docs - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 07:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 08:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 09:01:00 UTC, 0 replies.
- [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/05 09:12:33 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-20508) Do not log/throw error/exception for corrupted tasks due to compacted changelog topic - posted by "Kartikay Dubey (Jira)" <ji...@apache.org> on 2026/05/05 10:32:00 UTC, 0 replies.
- [PR] KAFKA-20551: Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/05 10:39:40 UTC, 1 replies.
- Re: [PR] KAFKA-18652: Add `acceptable.recovery.lag` config [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/05/05 14:43:15 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-17999) Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 14:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-20440: Use default Keystore type instead of hardcoding PKCS12 keystore type [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/05 14:56:37 UTC, 9 replies.
- [PR] Test [kafka] - posted by "traceyyoshima (via GitHub)" <gi...@apache.org> on 2026/05/05 15:14:23 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/05 15:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/05 15:38:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics - posted by "RITIK KUMAR JAISWAL (Jira)" <ji...@apache.org> on 2026/05/05 16:10:00 UTC, 3 replies.
- [PR] initial config [kafka] - posted by "traceyyoshima (via GitHub)" <gi...@apache.org> on 2026/05/05 16:30:09 UTC, 2 replies.
- Re: [PR] KAFKA-15768: Fix getOnlyPartitionResult to handle FailedQueryResult [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/05 16:36:35 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-18563) move RaftClientTestContext xyzRpcVersion methods into RaftProtocol - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 16:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/05 16:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/05 16:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 16:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19009) Move MetadataCacheTest to metadata module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 16:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20552) Support log segments larger than 2 GB - posted by "Haifeng Chen (Jira)" <ji...@apache.org> on 2026/05/05 17:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20435) Move LogManagerTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/05 17:29:00 UTC, 0 replies.
- [PR] KSTREAMS-8781: Add back `rack.aware.assignment.tags` config [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/05/05 17:36:59 UTC, 13 replies.
- [jira] [Resolved] (KAFKA-20372) Flaky NamedTopologyIntegrationTest shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/05 19:05:00 UTC, 0 replies.
- [jira] (KAFKA-20541) Duplicate generated folder in kafka-site - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/05 19:11:00 UTC, 0 replies.
- [PR] KAFKA-20444: [2/N] Update OffsetMetadataManager to use new TxnOffsetCommit errors (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/05 19:14:56 UTC, 3 replies.
- [PR] KAFKA-20444: [3/N] Allow building TxnOffsetCommit v6 requests with topic IDs (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/05 19:22:36 UTC, 3 replies.
- Re: [PR] KAFKA-20380; backwards compatible advertised.listeners when it is not defined [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/05 19:41:52 UTC, 11 replies.
- Re: [PR] KAFKA-20193: Remove `static T value(...)` method from ValueTimestampHeadersDeserializer if not needed [kafka] - posted by "asknishant (via GitHub)" <gi...@apache.org> on 2026/05/05 20:22:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20407) Consider adding transaction state log append latency metrics - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2026/05/05 20:56:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup - posted by "Jerome Waibel (Jira)" <ji...@apache.org> on 2026/05/05 21:23:00 UTC, 4 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/05/05 21:44:00 UTC, 1 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/05/05 21:45:00 UTC, 0 replies.
- Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/05 22:29:38 UTC, 6 replies.
- [jira] [Created] (KAFKA-20553) Eliminate the dependencies on "sourceSets.test.output" - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 22:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20553) Eliminate the dependencies on "sourceSets.test.output" - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/05 22:48:00 UTC, 1 replies.
- [PR] MINOR: Move AdminClient timeout test to Java and remove internal factory hack [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/06 01:36:37 UTC, 0 replies.
- Re: [PR] KAFKA-20452: Avoid creating unnecessary empty batches in LogCleaner below the High Watermark [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/06 02:06:46 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8295) Add merge() operator to State Stores. - posted by "Soumitra Kumar (Jira)" <ji...@apache.org> on 2026/05/06 02:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8295) Add merge() operator to State Stores. - posted by "Soumitra Kumar (Jira)" <ji...@apache.org> on 2026/05/06 02:59:00 UTC, 1 replies.
- Re: [PR] docs: suggest documentation improvements for better user experience [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 04:21:06 UTC, 6 replies.
- Re: [PR] MINOR: Fix listener configuration docs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 04:21: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/05/06 04:21:11 UTC, 0 replies.
- Re: [PR] KAFKA-20019: Fetch responses can exceed maxBytes when mixing local and tiered storage partitions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/06 04:40:58 UTC, 1 replies.
- [PR] KAFKA-10844: KStream mark as partitioned [kafka] - posted by "zheguang (via GitHub)" <gi...@apache.org> on 2026/05/06 06:33:22 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/05/06 06:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/05/06 06:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller - posted by "Sven Dewit (Jira)" <ji...@apache.org> on 2026/05/06 07:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20517) Kafka 4.1 upgrade docs missing server upgrade procedure under 4.1.0 heading - posted by "Erik Skytthe (Jira)" <ji...@apache.org> on 2026/05/06 09:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false - posted by "Pavel Cermak (Jira)" <ji...@apache.org> on 2026/05/06 09:40:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20245) Implementation for dead-letter queues for share groups in Share Partition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/05/06 10:17:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20245) Implementation for dead-letter queues for share groups in Share Partition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/05/06 10:35:00 UTC, 0 replies.
- Re: [PR] MINOR: Cherry-pick KAFKA-19851: Delete dynamic configs that were removed by Kafka to 4.2 [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/06 10:56:29 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19851) Delete dynamic config that were removed by Kafka - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/06 11:04:00 UTC, 7 replies.
- [PR] HOTFIX: SharePartition compile error [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/06 12:05:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment - posted by "Nurzhan (Jira)" <ji...@apache.org> on 2026/05/06 12:30:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false - posted by "Julian Bergner (Jira)" <ji...@apache.org> on 2026/05/06 13:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false - posted by "Julian Bergner (Jira)" <ji...@apache.org> on 2026/05/06 13:45:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-20554) Document or clarify acks=1 durability during planned leader transitions - posted by "Julian Bergner (Jira)" <ji...@apache.org> on 2026/05/06 13:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20554) Document or clarify acks=1 durability during planned leader transitions - posted by "Julian Bergner (Jira)" <ji...@apache.org> on 2026/05/06 13:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20554) Document or clarify acks=1 durability during planned leader transitions - posted by "Julian Bergner (Jira)" <ji...@apache.org> on 2026/05/06 14:46:00 UTC, 0 replies.
- Re: [PR] HOTFIX: Fix SharePartition build error [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/06 15:05:46 UTC, 0 replies.
- [PR] KAFKA-20444: [4/N] Prepare TxnOffsetCommitResponse for topic IDs (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/06 15:46:55 UTC, 1 replies.
- [PR] MINOR: Rewrite LogCleanerTest in Java and move it to storage module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/06 17:19:10 UTC, 10 replies.
- Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka] - posted by "joerauschenbusch (via GitHub)" <gi...@apache.org> on 2026/05/06 17:23:27 UTC, 2 replies.
- Re: [PR] MINOR: Move testCallInFlightTimeouts to Java and remove internal factory hack [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/06 18:29:23 UTC, 7 replies.
- [PR] MINOR: fix DynamicBrokerReconfigurationTest [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/06 18:34:26 UTC, 5 replies.
- [jira] [Commented] (KAFKA-20530) Log cluster.id at startup phase - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/06 18:44:00 UTC, 0 replies.
- [PR] MINOR: Removed stale Javadoc comment [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2026/05/06 19:03:29 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners if the latter is not defined - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/06 19:19:00 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners if the latter is not defined - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/06 19:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20552) Support log segments larger than 2 GB - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/06 19:25:00 UTC, 2 replies.
- Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/06 21:50:33 UTC, 1 replies.
- [PR] MINOR: TopologyTestDriver can reuse compiled Patterns for topic names [kafka] - posted by "stevenschlansker (via GitHub)" <gi...@apache.org> on 2026/05/06 23:26:37 UTC, 3 replies.
- [jira] [Updated] (KAFKA-20552) Support log segments larger than 2 GB - posted by "Haifeng Chen (Jira)" <ji...@apache.org> on 2026/05/06 23:58:00 UTC, 0 replies.
- [PR] KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" (Server-common) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/07 01:00:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20075) Side effects of 'preferred leader election' schedule change - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/05/07 02:18:00 UTC, 1 replies.
- Re: [PR] KAFKA-19673: Disallow create too many partitions also in createPartitions [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 04:42:03 UTC, 1 replies.
- Re: [PR] MINOR: Improve efficiency of `Uuid.randomUuid` [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 06:00:18 UTC, 2 replies.
- Re: [PR] KAFKA-19669: Merge repartition topics when value-changing operations are present [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 06:00:19 UTC, 1 replies.
- Re: [PR] KAFKA-17676: Fix NPE when starting tasks after config topic compaction [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 06:00:25 UTC, 1 replies.
- Re: [PR] KAFKA-20440: PEM certificate support should not depend on PKCS12 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 06:47:38 UTC, 2 replies.
- Re: [PR] KAFKA-20531: ducker-ak: Add --clean-build option to replace REBUILD env var [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/07 06:47:38 UTC, 0 replies.
- [PR] MINOR: Use short instead of int for requestType and requestVersion in AuthorizableRequestContext [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/07 07:02:44 UTC, 4 replies.
- Re: [PR] MINOR: Cherry-pick KAFKA-19851: Delete dynamic configs that were removed by Kafka to 4.1 [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/07 09:28:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-20555) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 09:42:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-20556) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 09:44:06 UTC, 0 replies.
- [jira] [Created] (KAFKA-20557) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 09:47:04 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20556) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 09:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20557) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 09:48:00 UTC, 0 replies.
- [PR] KAFKA-20557: Use jakarta.annotation.Priority in JaasBasicAuthFilter [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/07 10:04:04 UTC, 1 replies.
- [PR] KAFKA-20555: Use jakarta.annotation.Priority in JaasBasicAuthFilter [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/07 10:09:52 UTC, 3 replies.
- [PR] KAFKA-20554: Document acks=1 record loss during planned leader transitions [kafka] - posted by "julianbergner (via GitHub)" <gi...@apache.org> on 2026/05/07 10:53:31 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20555) JaasBasicAuthFilter should use jakarta.annotation - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/05/07 10:58:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2026/05/07 12:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2026/05/07 12:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/07 12:23:00 UTC, 1 replies.
- Re: [PR] MINOR: Fix outdated Javadoc link in AuthorizableRequestContext [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/07 12:26:48 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2026/05/07 13:52:00 UTC, 0 replies.
- [PR] KAFKA-20558: NPE ClusterInstance.waitUntilLeaderIsElectedOrChanged [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2026/05/07 14:58:17 UTC, 5 replies.
- [PR] KAFKA-14228 Support for nested structures: ValueToKey [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/07 15:03:41 UTC, 7 replies.
- [PR] Draft PR for KIP1241 Code compare [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/05/07 15:45:56 UTC, 1 replies.
- [jira] [Created] (KAFKA-20559) Revisit NOTICE-binary - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/07 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20559) Revisit NOTICE-binary - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/07 16:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-19620: Move AutoTopicCreationManager to server module [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/05/07 16:24:54 UTC, 17 replies.
- [jira] [Commented] (KAFKA-20559) Revisit NOTICE-binary - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2026/05/07 16:31:00 UTC, 3 replies.
- [PR] KAFKA-14229 Support for nested structures: HoistField [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/07 16:46:13 UTC, 2 replies.
- Re: [PR] MINOR: tidy up SocketServerMemoryPoolTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/07 16:52:54 UTC, 9 replies.
- [jira] [Updated] (KAFKA-20555) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 16:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20555) JaasBasicAuthFilter should use jakarta.annotation - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/07 16:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20559) Revisit NOTICE-binary - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/07 17:00:00 UTC, 0 replies.
- Re: [PR] KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" (Server-common) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/07 18:14:53 UTC, 2 replies.
- Re: [PR] MINOR: Cherry-pick KAFKA-19851: Delete dynamic configs that were removed by Kafka to 4.0 [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/07 18:21:41 UTC, 0 replies.
- Re: [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/07 18:36:32 UTC, 10 replies.
- [PR] KAFKA-20444: [5/N] Resolve TxnOffsetCommit topic IDs in KafkaApis (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/07 21:05:45 UTC, 7 replies.
- [PR] KAFKA-20444: [6/N] Handle GROUP_ID_NOT_FOUND and STALE_MEMBER_EPOCH in TransactionManager (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/07 21:23:38 UTC, 4 replies.
- [PR] Support for nested structures: MaskField [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/07 21:47:27 UTC, 1 replies.
- Re: [PR] MINOR: Fix Punctuator Javadocs for old and new ProcessorContext reference [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/07 23:15:33 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/08 02:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:08:55 UTC, 3 replies.
- Re: [PR] KAFKA-18171: Unexpected Change in bootstrap.servers Behavior After Upgrade to 3.8.0 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:32:29 UTC, 1 replies.
- Re: [PR] Fix IllegalStateException for Transaction Producer [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:32:31 UTC, 1 replies.
- Re: [PR] KAFKA-20125: Improve the docs of dynamic-only configurations [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/08 04:32:41 UTC, 4 replies.
- [jira] [Updated] (KAFKA-20560) Support non-blocking DeleteRecordsRequest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/08 04:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20560) Support non-blocking DeleteRecordsRequest - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/08 04:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20561) Enable batching in the kafka reassignment script - posted by "Manan Gupta (Jira)" <ji...@apache.org> on 2026/05/08 05:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20560) Support non-blocking DeleteRecordsRequest - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2026/05/08 07:23:00 UTC, 0 replies.
- [PR] KAFKA-20549: Intd new cache helper interface for DLQ manager. [2/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/08 09:08:45 UTC, 12 replies.
- [PR] KAFKA-20385: Add consumer-aware methods to ConsumerRebalanceListener [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/05/08 14:13:37 UTC, 9 replies.
- [jira] [Updated] (KAFKA-20418) Consider adding metrics for pending transaction markers and oldest transaction age - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/08 14:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20418) Consider adding metrics for pending transaction markers and oldest transaction age - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/08 14:15:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20562) Align StreamsGroup dynamic member updates with KIP-1071 epoch bump rules - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/08 14:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-19415 Shuffle the order of readPartitionInfo when fetching data. [kafka] - posted by "paulolieuthier (via GitHub)" <gi...@apache.org> on 2026/05/08 14:53:38 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/05/08 19:44:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-19807) Add RPC-level integration tests for StreamsGroupHeartbeat - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/05/08 21:35:00 UTC, 0 replies.
- Re: [PR] KAFKA-20193: Remove unused code [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/08 23:24:32 UTC, 1 replies.
- Re: [PR] KAFKA-20078: Fix exit codes in CLI tools using mainNoExit pattern [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/05/09 02:16:45 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky - posted by "chomingi (Jira)" <ji...@apache.org> on 2026/05/09 03:59:00 UTC, 0 replies.
- Re: [PR] KAFKA-19381 add config key builder [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 04:14:01 UTC, 0 replies.
- Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - client (4/N) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/09 04:35:57 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20558) NPE in ClusterInstance.waitUntilLeaderIsElectedOrChanged causes flaky tests - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/09 04:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/05/09 05:22:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/05/09 05:23:00 UTC, 0 replies.
- [PR] MINOR: Use testFixturesImplementation instead of testFixturesApi [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/09 06:11:14 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-20114) Fix race between requestInFlight and backoffDeadlineMs in RPCProducerIdManager causing premature retries - posted by "Sean Quah (Jira)" <ji...@apache.org> on 2026/05/09 06:14:00 UTC, 0 replies.
- Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/09 07:23:28 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager - posted by "Jiayao Sun (Jira)" <ji...@apache.org> on 2026/05/09 07:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect - posted by "Atriya (Jira)" <ji...@apache.org> on 2026/05/09 09:30:00 UTC, 1 replies.
- [PR] Eliminate the dependencies on sourceSets.test.output for storage:storage-api [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/09 10:37:47 UTC, 0 replies.
- Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/09 12:34:53 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20545) Flaky tests in MirrorConnectorsIntegrationSSLTest - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/09 12:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17715) Remove `force_use_zk_connection` from e2e - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/09 12:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17715) Remove `force_use_zk_connection` from e2e - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/09 12:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20523) Class name mismatch for LoggerFactory.getLogger method in KStreamKTableJoinProcessor.java - posted by "Gavin Wang (Jira)" <ji...@apache.org> on 2026/05/09 16:16:00 UTC, 0 replies.
- [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol (1/N) [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/10 01:52:46 UTC, 38 replies.
- Re: [PR] KAFKA-20553 : Eliminate the dependencies on sourceSets.test.output for storage:storage-api [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/10 03:14:06 UTC, 0 replies.
- [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (WIP) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/10 04:17:56 UTC, 1 replies.
- Re: [PR] MINOR: Rewrite RaftClusterSnapshotTest from Scala to Java [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 04:26:15 UTC, 4 replies.
- Re: [PR] Clarification of topic configuration 'retention.bytes' [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 04:45:58 UTC, 1 replies.
- Re: [PR] KAFKA-16109: Add system test for simple consumer commit and restart [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/10 04:46:04 UTC, 1 replies.
- [PR] KAFKA-20553 : Eliminate the dependencies on sourceSets.test.output for metadata [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/10 05:41:05 UTC, 11 replies.
- [jira] [Resolved] (KAFKA-18447) Support SASL_SSL protocol with java.security.auth.login.config - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2026/05/10 07:47:00 UTC, 0 replies.
- [PR] KAFKA-MM2: Add data loss detection and topic reset recovery to MirrorSourceTask [kafka] - posted by "TirumalaSrividya (via GitHub)" <gi...@apache.org> on 2026/05/10 10:47:47 UTC, 1 replies.
- Re: [PR] KAFKA-14227 Support for nested structures: MaskField [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/10 13:56:46 UTC, 2 replies.
- Re: [PR] KAFKA-20379: ducker-ak has no option to skip the gradlew systemTestLibs build step [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/05/10 14:06:30 UTC, 5 replies.
- Re: [PR] KAFKA-20419 : docker - Adding sasl_plain docker compose examples [kafka] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/05/10 14:25:30 UTC, 3 replies.
- [PR] KAFKA-20444: [7/N] Wire topic IDs through OffsetMetadataManager (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/10 16:25:12 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/10 17:35:00 UTC, 0 replies.
- [PR] MINOR: Clean up OffsetCommit request/response validation tests in KafkaApisTest [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/10 19:35:10 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16876) TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/05/11 00:18:00 UTC, 0 replies.
- [PR] MINOR: Convert GroupOffsetsResetterOptions to record [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/11 01:11:30 UTC, 1 replies.
- [PR] MINOR: Rewrite FetchFromFollowerIntegrationTest from Scala to Java and move to server module [kafka] - posted by "cychiu8 (via GitHub)" <gi...@apache.org> on 2026/05/11 04:35:35 UTC, 21 replies.
- Re: [PR] KAFKA-19687: MetaDataShell log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/11 04:50:23 UTC, 1 replies.
- [jira] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/05/11 05:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity test [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/11 05:30:43 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions - posted by "Sruthi Sathyamoorthy (Jira)" <ji...@apache.org> on 2026/05/11 06:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/11 08:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/11 08:07:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/11 08:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/11 08:30:00 UTC, 0 replies.
- [PR] docs: Document actual ProducerRecord default partitioner strategy [kafka] - posted by "dbottini2 (via GitHub)" <gi...@apache.org> on 2026/05/11 08:52:38 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-18824) Update docs of docker hub to add dynamic voters description - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/05/11 11:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-18824) Update docs of docker hub to add dynamic voters description - posted by "Maros Orsak (Jira)" <ji...@apache.org> on 2026/05/11 11:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch - posted by "Michael Westerby (Jira)" <ji...@apache.org> on 2026/05/11 12:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15853) Move KafkaConfig to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/11 13:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20535) Investigate potential improvements to async consumer CPU usage under low max.poll.records - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/11 13:28:00 UTC, 0 replies.
- [PR] KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/11 13:49:11 UTC, 0 replies.
- [jira] [Created] (KAFKA-20564) Move AuthorizerTest to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/11 14:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20565) Flaky testAutoCommitSentBeforePositionUpdate - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/11 16:49:00 UTC, 0 replies.
- [PR] KAFKA-20444: [8/N] Extend TxnOffsetCommit integration tests to v6 (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/11 16:52:14 UTC, 1 replies.
- Re: [PR] KAFKA-20424 : clients: Update KafkaConsumerTest comments,tests with relevant protocol [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/05/11 16:52:43 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20565) Flaky testAutoCommitSentBeforePositionUpdate - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/11 16:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20566) Share group deletion in performance test sometimes gets stuck - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/11 17:00:00 UTC, 0 replies.
- [PR] KAFKA-20565 : Fix flaky test testAutoCommitSentBeforePositionUpdate timeout [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/11 17:33:42 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/11 18:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19594) Multiple-partition topic support for TopologyTestDriver - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/11 18:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-18950) Allow to "shift" window-start anchor for Tumbling/Hopping windows - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/11 18:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12928) Add a check whether the Task's statestore is actually a directory - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/11 19:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping - posted by "Lucy Liu (Jira)" <ji...@apache.org> on 2026/05/11 20:26:00 UTC, 0 replies.
- [PR] KAFKA-20566: Improve logging in share coordinator [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/05/11 20:30:43 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20566) Share group deletion in performance test sometimes gets stuck - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/11 20:33: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 "josefk31 (via GitHub)" <gi...@apache.org> on 2026/05/11 21:38:11 UTC, 7 replies.
- [PR] MINOR: Add documentation for the num-keys metric introduced by KIP-1250 [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/05/11 22:13:12 UTC, 2 replies.
- Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for group-coordinator and share-coordinator [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/11 22:44:37 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20285) Mpve UncleanLeaderElectionTest to server module - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2026/05/11 22:47:00 UTC, 1 replies.
- [PR] MINOR: Assert queryable state range results [kafka] - posted by "codingkiddo (via GitHub)" <gi...@apache.org> on 2026/05/12 02:20:04 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15648) QuorumControllerTest#testBootstrapZkMigrationRecord is flaky - posted by "Sandeep (Jira)" <ji...@apache.org> on 2026/05/12 03:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15722) KRaft support in RackAwareAutoTopicCreationTest - posted by "Sandeep (Jira)" <ji...@apache.org> on 2026/05/12 03:39:00 UTC, 0 replies.
- Re: [PR] MINOR: add unit test for TransactionLog.readTxnRecordKey [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 04:44:02 UTC, 1 replies.
- Re: [PR] MINOR: Add java version check command to README [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 04:44:07 UTC, 0 replies.
- Re: [PR] KAFKA-20099: Clarify how stream-time works in the docs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/12 04:44:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-20567) Skip loading UnifiedLog for stray replicas during broker startup - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/12 06:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20567) Skip loading UnifiedLog for stray replicas during broker startup - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/05/12 07:30:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20285) Mpve UncleanLeaderElectionTest to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/12 07:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20549) Implementation of Share Group DLQ Manager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/05/12 08:54:00 UTC, 1 replies.
- Re: [PR] KAFKA-19648: KIP-1170 Unify cluster metadata bootstrapping [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/12 11:01:25 UTC, 6 replies.
- [jira] [Created] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/12 11:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20569) Doc doesn't have upgrading steps - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/05/12 11:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19851) Delete dynamic config that were removed by Kafka - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/12 12:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20380) controller.quorum.voters should act as advertised.listeners if the latter is not defined - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/12 12:48:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-19851) Delete dynamic config that were removed by Kafka - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/12 13:06:00 UTC, 0 replies.
- [PR] Add explicit least-privilege permissions to GitHub workflows [kafka] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/12 13:16:34 UTC, 5 replies.
- [PR] KAFKA-20564: Move AuthorizerTest to server [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/12 13:37:46 UTC, 7 replies.
- [PR] Fix documentation typos in protocol and upgrade guides [kafka] - posted by "arpitjain099 (via GitHub)" <gi...@apache.org> on 2026/05/12 14:20:41 UTC, 4 replies.
- [jira] [Created] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2026/05/12 14:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20570) Catch RuntimeException in ConsumerProtocol deserialization in group coordinator - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2026/05/12 14:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20569) Doc doesn't have upgrading steps - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/12 14:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset - posted by "Daeho Kwon (Jira)" <ji...@apache.org> on 2026/05/12 14:57:00 UTC, 0 replies.
- [PR] KAFKA-20569: Add upgrade instructions for 4.2 and 4.3 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/12 15:08:26 UTC, 8 replies.
- [jira] [Created] (KAFKA-20571) InMemory KeyValue store metric throws exception - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/12 15:11:00 UTC, 0 replies.
- [PR] KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserialization in group coordinator [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/05/12 15:26:11 UTC, 11 replies.
- [jira] [Updated] (KAFKA-20571) InMemory KeyValue store metric throws exception - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/12 15:29:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20571) InMemory KeyValue store metric throws exception - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/12 15:33:00 UTC, 0 replies.
- Re: [PR] MINOR: follow-up of KAFKA-20317 [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/05/12 15:42:31 UTC, 0 replies.
- [PR] KAFKA-20444: [9/N] Preserve topic-level structure in TxnOffsetCommit response handling (KIP-1319) [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2026/05/12 17:06:59 UTC, 1 replies.
- [PR] KAFKA-20559: Update NOTICE-binary and add verify_notice.py [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/12 17:38:54 UTC, 10 replies.
- [PR] KAFKA-20571: Added store unwrapping for publishing num-keys metric. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/12 18:28:51 UTC, 10 replies.
- [jira] [Created] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/12 20:00:00 UTC, 0 replies.
- [PR] KAFKA-20563: Fix flaky ShareConsumerRackAwareTest [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/05/12 20:00:39 UTC, 9 replies.
- [jira] [Updated] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/12 20:01:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/12 20:04:00 UTC, 1 replies.
- [PR] KAFKA-20572: Fix NPE when using listener-prefixed SSL configs [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/12 20:10:59 UTC, 7 replies.
- [jira] [Created] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging - posted by "Haifeng Chen (Jira)" <ji...@apache.org> on 2026/05/12 20:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/12 20:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/12 20:45:00 UTC, 0 replies.
- [PR] KAFKA-20385 [1/N]: Add RebalanceConsumer interface and callback impl [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/05/12 21:30:29 UTC, 43 replies.
- [PR] KAFKA-20385 [2/N]: Add setConsumerRebalanceListener into *Consumer [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/05/12 22:52:46 UTC, 1 replies.
- [PR] KAFKA-20385 [3/N]: Integration tests + examples [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/05/12 22:53:23 UTC, 1 replies.
- [jira] [Created] (KAFKA-20575) Add onPartitionsLost support for MockConsumer - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/12 23:15:00 UTC, 0 replies.
- [PR] KAFKA-20575: Add onPartitionsLost support for MockConsume [kafka] - posted by "adikou (via GitHub)" <gi...@apache.org> on 2026/05/12 23:18:24 UTC, 2 replies.
- Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/05/12 23:22:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-17689) Migrate TieredStorageTestHarness to new test infra - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/12 23:46:00 UTC, 0 replies.
- [PR] KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" (raft) [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/13 04:25:48 UTC, 0 replies.
- Re: [PR] KAFKA-17207: Recreate config topic in Connect test to prevent thread … [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 04:46:21 UTC, 1 replies.
- Re: [PR] MINOR: Add character range support to Glob patterns in Kafka shell [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 04:46:29 UTC, 1 replies.
- Re: [PR] Minor: Preserve user-provided acks config without mutation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/13 04:46:33 UTC, 3 replies.
- [PR] MINOR: Publish kafka-clients test-fixtures artifact [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/13 05:36:16 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20571) InMemory KeyValue store metric throws exception - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/13 06:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20572) Connect REST server throws NPE on startup when using listener-prefixed SSL configs - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/13 07:51:00 UTC, 0 replies.
- [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for server and storage module [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/13 09:50:48 UTC, 2 replies.
- [PR] MINOR: Fix race in StreamsGroupHeartbeatRequestTest testDynamicGroupConfig [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/05/13 10:46:10 UTC, 1 replies.
- [PR] KAFKA-20145: Avoid redundant partial HB acks from network-thread reconcile [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/13 11:30:28 UTC, 13 replies.
- [jira] [Commented] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/13 12:18:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/13 13:45:00 UTC, 0 replies.
- [PR] MINOR: Enable testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl f… [kafka] - posted by "kuoche1712003 (via GitHub)" <gi...@apache.org> on 2026/05/13 15:46:18 UTC, 12 replies.
- [jira] [Assigned] (KAFKA-20440) PEM certificate support should not depend on PKCS12 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/13 16:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20253) High CPU loop on consumer after failed re-authentication - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/13 16:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20576) Dynamic memory allocation for the KafkaProducer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/13 18:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20577) Producer configuration to define allocation strategy - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/13 18:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20579) Implement dynamic allocation for compressed data - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/13 18:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20578) Implement dynamic allocation for uncompressed data - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/13 18:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20580) Scatter-gather support for producer dynamic allocation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/13 18:53:00 UTC, 0 replies.
- Re: [PR] KAFKA-20553: Eliminate the dependencies on "sourceSets.test.output" (raft) [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/13 19:18:03 UTC, 0 replies.
- [PR] KAFKA-20574 : SimpleConfigRepository in the storage module could be replaced by MockConfigRepository [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/13 19:33:01 UTC, 1 replies.
- [PR] KAFKA-20553 : Eliminate the dependencies on sourceSets.test.output for coordinator-common module [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/13 19:55:34 UTC, 2 replies.
- [jira] [Created] (KAFKA-20581) Move MockAclMutator alongside AuthorizerTest, when AuthorizerTest is migrated out of core - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/13 20:24:00 UTC, 0 replies.
- [PR] [KAFKA-16876] TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit [kafka] - posted by "gabriellefu (via GitHub)" <gi...@apache.org> on 2026/05/13 22:20:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20515) ZK leader failover during ZK migration can block migration - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/05/14 03:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2026/05/14 03:09:00 UTC, 0 replies.
- Re: [PR] MINOR Clarified maximum length of COMPACT_STRING [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/14 04:46:23 UTC, 1 replies.
- [PR] Add .bob/ to .gitignore [kafka] - posted by "mcascallares (via GitHub)" <gi...@apache.org> on 2026/05/14 08:54:27 UTC, 1 replies.
- [jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/05/14 09:20:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 09:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20563) Flaky test ShareConsumerRackAwareTest.testShareConsumerWithRackAwareAssignor - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/14 10:13:00 UTC, 0 replies.
- [PR] KAFKA-20549: Add logic for create topic in DLQ state manager. [3/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/14 10:36:09 UTC, 6 replies.
- [jira] [Created] (KAFKA-20582) KRaft restart/restore instability when ACL enabled and CQ uses allow.everyone.if.no.acl.found=true without super.users - posted by "Swathi Mocharla (Jira)" <ji...@apache.org> on 2026/05/14 11:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20583) KRaft controller does not support dynamic SSL certificate reload for CONTROLLER listener unlike broker listeners - posted by "Swathi Mocharla (Jira)" <ji...@apache.org> on 2026/05/14 11:53:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix documentation typos in protocol and upgrade guides [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/14 12:06:00 UTC, 0 replies.
- [PR] MINOR: Fix Streams query result Javadocs [kafka] - posted by "pony-maggie (via GitHub)" <gi...@apache.org> on 2026/05/14 12:32:45 UTC, 0 replies.
- [jira] [Created] (KAFKA-20584) issue in SASL oauthbearer flow for kraft version in kafka 4.2 - posted by "Kalyan Ram chowdary purimetla (Jira)" <ji...@apache.org> on 2026/05/14 13:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20584) issue in SASL oauthbearer flow for kraft version in kafka 4.2 - posted by "Kalyan Ram chowdary purimetla (Jira)" <ji...@apache.org> on 2026/05/14 13:34:00 UTC, 2 replies.
- [PR] MINOR: Fix delegation token docs typo [kafka] - posted by "pony-maggie (via GitHub)" <gi...@apache.org> on 2026/05/14 13:34:07 UTC, 3 replies.
- Re: [PR] MINOR: Update javadocs for GroupConfig and GroupConfigManager [kafka] - posted by "squah-confluent (via GitHub)" <gi...@apache.org> on 2026/05/14 13:55:25 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-20440) PEM certificate support should not depend on PKCS12 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/14 16:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Shivsundar R (Jira)" <ji...@apache.org> on 2026/05/14 17:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20562) Align StreamsGroup dynamic member updates with KIP-1071 epoch bump rules - posted by "Gavin Wang (Jira)" <ji...@apache.org> on 2026/05/14 18:19:00 UTC, 0 replies.
- [PR] KAFKA-18766: Clarify allow.everyone.if.no.acl.found in ACL docs [kafka] - posted by "Hana1025 (via GitHub)" <gi...@apache.org> on 2026/05/14 19:08:54 UTC, 1 replies.
- [jira] [Created] (KAFKA-20586) Flaky : LeaderElectionCommandTest > testPreferredReplicaElection [1] Type=Raft-Isolated, MetadataVersion=4.4-IV0 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20586) Flaky : LeaderElectionCommandTest > testPreferredReplicaElection [1] Type=Raft-Isolated, MetadataVersion=4.4-IV0 - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20589) Add restore.buffered.records.per.partition config and enforce cap in StoreChangelogReader - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20590) Add integration test coverage for restore.buffered.records.per.partition cap - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20591) Document restore.buffered.records.per.partition in Streams developer guide - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 19:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/14 20:32:00 UTC, 0 replies.
- [PR] MINOR: some code cleanup [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/14 23:32:09 UTC, 5 replies.
- [jira] [Updated] (KAFKA-18628) Deprecate broker.id - posted by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/05/15 01:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19753) Metrics from FetchMetricsManager containing a topic tag are duplicated - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 02:07:00 UTC, 0 replies.
- [PR] MINOR: Use MetadataRecordSerde.INSTANCE in RaftClusterSnapshotTest [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/15 03:43:34 UTC, 2 replies.
- Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 04:47:02 UTC, 0 replies.
- Re: [PR] Fix high-watermark metric returning -1 for leader [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 04:47:06 UTC, 1 replies.
- Re: [PR] Strategy based implementation of acquire mode in SharePartition [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/15 04:47:10 UTC, 1 replies.
- [PR] MINOR: Scala to Java migration. Migrated some tests from PlaintextAdminIntegrationTest to a new java class. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/15 05:16:49 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-20443) Move RequestChannel Requests to server module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/15 05:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/15 07:21:00 UTC, 0 replies.
- Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/15 07:35:53 UTC, 4 replies.
- [PR] KAFKA-20545: Fix flaky MirrorConnectorsIntegrationSSLTest testConnectorMetrics* tests [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/15 08:59:13 UTC, 6 replies.
- [jira] [Commented] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/15 09:24:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/15 09:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/15 10:09:00 UTC, 0 replies.
- Re: [PR] KAFKA-16876: TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/05/15 10:15:24 UTC, 10 replies.
- [PR] MINOR: Prevent this leak while DefaultStatePersister construction. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/15 10:22:31 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/05/15 10:38:00 UTC, 3 replies.
- [PR] KAFKA-20592: Fixes some typos in Streams Documentation [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/05/15 10:41:52 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/15 10:43:00 UTC, 3 replies.
- [jira] [Reopened] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/05/15 10:45:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/15 10:45:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20592) Fix several typos in Streams and upgrade documentation - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/15 10:46:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics - posted by "Ankur Sinha (Jira)" <ji...@apache.org> on 2026/05/15 11:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20564) Move AuthorizerTest to server module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/15 13:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20575) Add onPartitionsLost support for MockConsumer - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 13:13:00 UTC, 0 replies.
- [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/15 15:01:20 UTC, 13 replies.
- [jira] [Resolved] (KAFKA-20419) Add SASL docker compose examples for single-node and multi-node clusters - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/05/15 15:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693 - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/05/15 15:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693 - posted by "Kirk True (Jira)" <ji...@apache.org> on 2026/05/15 15:40:00 UTC, 1 replies.
- [PR] MINOR: Use NullNode instead of empty TextNode for missing request/response fields [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/15 16:01:13 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20496) Interactive Query isolation level configuration and framework - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/15 16:36:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/15 16:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20575) Add onPartitionsLost support for MockConsumer - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 18:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20575) Add onPartitionsLost support for MockConsumer - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 18:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/15 18:34:15 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20386) SerDe and Interceptor Metrics - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 19:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20387) Extend RecordHeader API for Common Value Types - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 19:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 19:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20384) Per-Record Context Processing for Kafka Consumers - posted by "Aditya Kousik (Jira)" <ji...@apache.org> on 2026/05/15 19:30:00 UTC, 0 replies.
- Re: [PR] KAFKA-19483 : storage : Fix resource leak, cleanup [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/15 19:58:12 UTC, 0 replies.
- [PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/15 20:37:29 UTC, 13 replies.
- [jira] [Assigned] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/15 20:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/15 20:39:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/15 20:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-19992) Allow to configure max memory for restore path - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 20:53:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20589) Add restore.buffered.records.per.partition config and enforce cap in StoreChangelogReader - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 20:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20590) Add integration test coverage for restore.buffered.records.per.partition cap - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 20:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20591) Document restore.buffered.records.per.partition in Streams developer guide - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 20:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 21:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19731) Remove AppInfoParser deprecated metrics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 21:59:00 UTC, 1 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [kafka-merge-queue-sandbox] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 22:09:47 UTC, 0 replies.
- [PR] [INFRA] Set up default rulesets for default and release branches [kafka] - posted by "asf-gitbox-commits (via GitHub)" <gi...@apache.org> on 2026/05/15 22:09:56 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-560) Garbage Collect obsolete topics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-560) Garbage Collect obsolete topics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-566) Add last modified time to the TopicMetadataRequest - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-747) RequestChannel re-design - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-747) RequestChannel re-design - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-740) Improve crash-safety of log segment swap - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-859) support basic auth protection of mx4j console - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-960) Upgrade Metrics to 3.x - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1014) Junits and system tests for inbuilt offset management - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1014) Junits and system tests for inbuilt offset management - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1063) run log cleanup at startup - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-740) Improve crash-safety of log segment swap - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1088) Ability to create a shadow consumer group - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1088) Ability to create a shadow consumer group - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1101) Need better java api for embedding kafkaserver in a java container app - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1122) Kafka can log giant log lines - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1206) allow Kafka to start from a resource negotiator system - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1299) Standardize configs across tools - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20492) Factor out RocksDBStore iteration methods to DBAccessor - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/15 22:33:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1300) Added WaitForReplaction admin tool. - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20489) Add config to control state wipe behaviour - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/15 22:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1352) Reduce logging on the server - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1351) String.format is very expensive in Scala - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1352) Reduce logging on the server - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1448) Filter-plugins for messages - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1450) check invalid leader in a more robust way - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:36:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1543) Changing replication factor - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1566) Kafka environment configuration (kafka-env.sh) - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1579) End-to-End tool to measure performance and correctness test - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1590) Binarize trace level request logging along with debug level text logging - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics - posted by "Jahnavi Patel (Jira)" <ji...@apache.org> on 2026/05/15 22:42:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1626) Use Jekyll for website - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1623) kafka is sometimes slow to accept connections - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1626) Use Jekyll for website - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1631) ReplicationFactor and under-replicated partitions incorrect during reassignment - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1639) Support control messages in Kafka - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1659) Ability to cleanly abort the KafkaProducer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1669) Default rebalance retries and backoff should be higher - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1669) Default rebalance retries and backoff should be higher - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 22:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 23:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/15 23:27:00 UTC, 2 replies.
- [PR] KAFKA-19790: Parse space-delimited OAuth scope claim strings [kafka] - posted by "lh0156 (via GitHub)" <gi...@apache.org> on 2026/05/16 03:02:44 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693 - posted by "Yunseop Eom (Jira)" <ji...@apache.org> on 2026/05/16 03:19:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20586) Flaky : LeaderElectionCommandTest > testPreferredReplicaElection [1] Type=Raft-Isolated, MetadataVersion=4.4-IV0 - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/16 05:21:00 UTC, 0 replies.
- [PR] KAFKA-20592: Fix typos in Streams documentation [kafka] - posted by "akhil-sabu-ibm (via GitHub)" <gi...@apache.org> on 2026/05/16 05:45:43 UTC, 1 replies.
- [jira] [Updated] (KAFKA-19663) kafka-broker-api tool should support to get controller api version - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2026/05/16 07:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20594) Kafka Streams issue - posted by "Aayush Gupta (Jira)" <ji...@apache.org> on 2026/05/16 08:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20560) Support non-blocking DeleteRecordsRequest - posted by "TaiJuWu (Jira)" <ji...@apache.org> on 2026/05/16 15:41:00 UTC, 0 replies.
- [PR] KAFKA-20549: Change ownership of DLQ state manager. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/16 21:00:47 UTC, 0 replies.
- Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka] - posted by "see-quick (via GitHub)" <gi...@apache.org> on 2026/05/16 21:25:34 UTC, 11 replies.
- [PR] KAFKA-9479: Print describe --state header once for multiple groups [kafka] - posted by "Hana1025 (via GitHub)" <gi...@apache.org> on 2026/05/17 04:33:57 UTC, 3 replies.
- Re: [PR] Return friendly prompt when no quota configs found [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 04:48:08 UTC, 1 replies.
- Re: [PR] KAFKA-20150: Add Structurizr scaffolding for C4 Diagrams [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/17 04:48:14 UTC, 1 replies.
- [jira] [Created] (KAFKA-20595) Parallelize loadSegmentFiles - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/17 08:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20595) Parallelize loadSegmentFiles - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/17 08:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20595) Parallelize loadSegmentFiles - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/17 08:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20595) Parallelize loadSegmentFiles - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/05/17 08:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20567) Skip loading UnifiedLog for stray replicas during broker startup - posted by "PoAn Yang (Jira)" <ji...@apache.org> on 2026/05/17 08:33:00 UTC, 0 replies.
- [PR] KAFKA-20409: Don't expose internal group configs unless they are user-defined [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/17 12:09:11 UTC, 8 replies.
- [jira] [Created] (KAFKA-20596) Consider exposing broker-reported Streams group heartbeat status via metrics - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/17 13:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20596) Consider exposing broker-reported Streams group heartbeat status via metrics - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/17 13:54:00 UTC, 1 replies.
- [PR] KAFKA-20586: Fix flaky LeaderElectionCommandTest.testPreferredReplicaElection [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/17 14:52:23 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics - posted by "RITIK KUMAR JAISWAL (Jira)" <ji...@apache.org> on 2026/05/17 15:06:00 UTC, 2 replies.
- [PR] KAFKA-4320: Clarify log compaction configuration docs [kafka] - posted by "Derekko-web (via GitHub)" <gi...@apache.org> on 2026/05/17 18:02:51 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20566) Share group deletion in performance test sometimes gets stuck - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/17 20:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-20549: Change ownership of DLQ state manager. [4/N] [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/05/17 21:03:58 UTC, 0 replies.
- Re: [PR] Kafka 16582 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/18 04:55:25 UTC, 1 replies.
- Re: [PR] KAFKA-19553: Add comprehensive unit tests for TemperatureDemo streams example [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/18 04:55:27 UTC, 1 replies.
- Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/18 04:55:35 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/18 08:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-17871: avoid blocking the herder thread when producer flushing hangs [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2026/05/18 08:49:16 UTC, 3 replies.
- [PR] MINOR: Add javadoc to share coord member fields and jobs. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/18 09:29:25 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V - posted by "Aryan Gupta (Jira)" <ji...@apache.org> on 2026/05/18 09:30:00 UTC, 0 replies.
- [PR] KAFKA-17689 Migrate TieredStorageTestHarness to new test infra (AlterLogDirTest) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/18 10:01:36 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-20545) Flaky tests in MirrorConnectorsIntegrationSSLTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/18 12:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20569) Doc doesn't have upgrading steps - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/18 12:56:00 UTC, 0 replies.
- [PR] KAFKA-18998: Move AuthHelper to server module [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/18 13:27:09 UTC, 4 replies.
- [PR] MINOR: Remove unnecessary null check in DefaultStatePersister#stop [kafka] - posted by "kuoche1712003 (via GitHub)" <gi...@apache.org> on 2026/05/18 15:02:22 UTC, 2 replies.
- [jira] [Created] (KAFKA-20597) prefixScan fails for prefixes with no upper bound in in-memory state stores - posted by "Pranav Chintareddy (Jira)" <ji...@apache.org> on 2026/05/18 15:54:00 UTC, 0 replies.
- [PR] KAFKA-20589 : Adding new streams config for restore path to handle memory issues [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/18 16:07:47 UTC, 12 replies.
- [PR] KAFKA-20597: Fix prefixScan overflow handling in in-memory state stores [kafka] - posted by "pchintar (via GitHub)" <gi...@apache.org> on 2026/05/18 16:11:17 UTC, 15 replies.
- [jira] [Assigned] (KAFKA-20582) KRaft restart/restore instability when ACL enabled and CQ uses allow.everyone.if.no.acl.found=true without super.users - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/18 16:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20582) KRaft restart/restore instability when ACL enabled and CQ uses allow.everyone.if.no.acl.found=true without super.users - posted by "Nilesh Kumar (Jira)" <ji...@apache.org> on 2026/05/18 16:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20598) Prevent polling unassigned consumer during ConsumerTask shutdown - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/18 16:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20598) Prevent polling unassigned consumer during ConsumerTask shutdown - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/18 16:55:00 UTC, 0 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to ChangeLogging stores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:55:47 UTC, 6 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to CachingKeyValueStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:00 UTC, 2 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to CachingSessionStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:09 UTC, 7 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to CachingWindowStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:19 UTC, 2 replies.
- [PR] KAFKA-20497: Add TimeOrderedCachingWindowStore#readOnly [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:26 UTC, 2 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredKeyValueStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:36 UTC, 2 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredSessionStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:44 UTC, 2 replies.
- [PR] KAFKA-20497: Add readOnly(IsolationLevel) to MeteredWindowStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/18 16:56:52 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20530) Log cluster.id at startup phase - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/18 19:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/18 19:19:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/18 19:19:00 UTC, 0 replies.
- [PR] KAFKA-20530: Log cluster.id at startup phase [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/18 19:34:06 UTC, 2 replies.
- [PR] KAFKA-20404: Replace bulk StreamThread atomicity excludes with field-level suppressions [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/18 19:53:33 UTC, 2 replies.
- [PR] MINOR: Fix typo in TransactionContext javadoc [kafka] - posted by "RonGamzu (via GitHub)" <gi...@apache.org> on 2026/05/18 20:29:30 UTC, 1 replies.
- [PR] KAFKA-20377: Forward --build-arg flags through ducker-ak [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/19 03:08:16 UTC, 1 replies.
- Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 04:51:40 UTC, 0 replies.
- Re: [PR] KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP] [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/19 04:51:40 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20594) Kafka Streams issue - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/19 06:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20599) Improve retry logic in KafkaStatusBackingStore with exponential backoff and retry limits - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/19 06:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20599) Improve retry logic in KafkaStatusBackingStore with exponential backoff and retry limits - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2026/05/19 08:16:00 UTC, 2 replies.
- [PR] KAFKA-20490: Add transaction buffer framework [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2026/05/19 08:44:02 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20599) Improve retry logic in KafkaStatusBackingStore with exponential backoff and retry limits - posted by "Akhil Sabu (Jira)" <ji...@apache.org> on 2026/05/19 08:45:00 UTC, 0 replies.
- [PR] KAFKA-20599: Improve retry logic in KafkaStatusBackingStore with exponential backoff [kafka] - posted by "akhil-sabu-ibm (via GitHub)" <gi...@apache.org> on 2026/05/19 09:24:48 UTC, 1 replies.
- Re: [PR] fix: architecture detection for Kafka heap options [kafka] - posted by "vbakke (via GitHub)" <gi...@apache.org> on 2026/05/19 10:41:01 UTC, 2 replies.
- [PR] KAFKA-20587: Wait for global store topic partitions in test setup [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/19 12:24:05 UTC, 1 replies.
- [PR] KAFKA-967 Use key range in ProducerPerformance (WIP) [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/19 12:46:55 UTC, 1 replies.
- [PR] MINOR: Fixed metrics decompression [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/19 14:00:23 UTC, 1 replies.
- Re: [PR] KAFKA-20024: wmic os get osarchitecture is unreliable for detecting OS bitness in bat scripts [kafka] - posted by "vbakke (via GitHub)" <gi...@apache.org> on 2026/05/19 15:54:04 UTC, 1 replies.
- [PR] KAFKA-20598: Prevent polling unassigned consumer during ConsumerTask shutdown [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/19 16:05:25 UTC, 1 replies.
- Re: [PR] KAFKA-19890: Fix stop command failure after wmic removal in newer Windows. [kafka] - posted by "vbakke (via GitHub)" <gi...@apache.org> on 2026/05/19 16:08:12 UTC, 1 replies.
- Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka] - posted by "vbakke (via GitHub)" <gi...@apache.org> on 2026/05/19 16:09:32 UTC, 2 replies.
- [PR] KAFKA-18810 : fix flaky ClientIdQuotaTest.testQuotaOverrideDelete [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/19 16:38:35 UTC, 4 replies.
- [jira] [Commented] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer - posted by "Sakshi Yadav (Jira)" <ji...@apache.org> on 2026/05/19 16:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files - posted by "Sakshi Yadav (Jira)" <ji...@apache.org> on 2026/05/19 16:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14490) Consider using UncheckedIOException instead of IOException in the log layer - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/19 18:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14490) Consider using UncheckedIOException instead of IOException in the log layer - posted by "Canxuan Wang (Jira)" <ji...@apache.org> on 2026/05/19 18:58:00 UTC, 0 replies.
- [PR] KAFKA-14490: Throw UncheckedIOException from LazyIndex [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/19 19:11:46 UTC, 2 replies.
- [PR] KAFKA-18087 : Revert unnecessary integration testing of both consumer group protocols (part 1) [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/19 19:36:57 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/19 19:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/19 19:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20565) Flaky testAutoCommitSentBeforePositionUpdate - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/20 01:19:00 UTC, 0 replies.
- [PR] MINOR: Re-read PRODUCE throttle metric each iteration in produceUntilThrottled [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/20 02:12:11 UTC, 2 replies.
- Re: [PR] jprnt02 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 04:53:27 UTC, 1 replies.
- Re: [PR] KAFKA-19048: Minimal movement replica balancing algorithm for reassignment [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 04:53:29 UTC, 1 replies.
- Re: [PR] MINOR: Note KS broker replication factor limitation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 04:53:31 UTC, 1 replies.
- Re: [PR] [Draft] KAFKA-19393: Consolidate consumer assignment state views. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/20 04:53:33 UTC, 1 replies.
- [PR] KAFKA-20404: Replace bulk DefaultStateUpdater atomicity excludes with field-level suppressions [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/20 08:26:30 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-18766) Docs: Make usage of allow.everyone.if.no.acl.found config clearer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/20 08:37:00 UTC, 0 replies.
- [PR] MINOR: Move TransactionStateManager leaf case classes to Java records in transaction-coordinator [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/05/20 09:16:15 UTC, 2 replies.
- Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 09:36:32 UTC, 0 replies.
- Re: [PR] # Kafka MirrorMaker 2 Enhancement Project [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 09:41:42 UTC, 1 replies.
- Re: [PR] Feat/mm2 fault tolerance [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 09:43:12 UTC, 1 replies.
- Re: [PR] Enhance MirrorMaker2 with fault tolerance for log truncation and topic reset [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 09:44:23 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4320) Log compaction docs update - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/20 09:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20600) Move AuthHelper.scala to server module - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/20 11:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20600) Move AuthHelper.scala to server module - posted by "Ken Huang (Jira)" <ji...@apache.org> on 2026/05/20 11:24:00 UTC, 0 replies.
- [PR] KAFKA-20600: Move AuthHelper.scala to server module. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/20 11:25:41 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-20600) Move AuthHelper.scala to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/20 11:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20601) ConsumerGroup static member rejoin can fail with GroupMaxSizeReachedException at max size - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/20 12:52:00 UTC, 0 replies.
- [PR] MINOR: Remove unused Response.onComplete method [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 15:36:14 UTC, 0 replies.
- [PR] MINOR: Add 4.3.0 to docker_scan workflow [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/20 16:11:32 UTC, 3 replies.
- Re: [PR] KAFKA-8504: Update Kafka Streams docs for suppress() operator [kafka] - posted by "nmarasoiu (via GitHub)" <gi...@apache.org> on 2026/05/20 17:59:35 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-18810) Flaky test: ClientIdQuotaTest.testQuotaOverrideDelete - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/21 01:30:00 UTC, 0 replies.
- Re: [PR] KAFKA-16263: Add listeners and callbacks section to Streams developer guide [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/05/21 02:31:19 UTC, 2 replies.
- Re: [PR] KAFKA-16263 Add Kafka Streams docs about available listeners/callback [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/05/21 02:33:04 UTC, 1 replies.
- Re: [PR] KAFKA-19979: Improve Kafka Streams config files [kafka] - posted by "ezhou413 (via GitHub)" <gi...@apache.org> on 2026/05/21 02:34:02 UTC, 1 replies.
- [PR] KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/21 03:39:36 UTC, 3 replies.
- [PR] MINOR: Split KafkaAdminClientTest into per-domain test classes [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/05/21 06:40:14 UTC, 4 replies.
- Re: [PR] KAFKA-19054: StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs [kafka] - posted by "ArneKlein (via GitHub)" <gi...@apache.org> on 2026/05/21 08:58:55 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-19620) Move AutoTopicCreationManager to server module - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/21 09:11:00 UTC, 0 replies.
- [PR] KAFKA-20404: Replace bulk TaskManager atomicity exclude with a field-level suppression [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/21 15:38:21 UTC, 1 replies.
- [PR] KAFKA-20404: Replace bulk StreamsPartitionAssignor atomicity exclude with field-level suppressions [kafka] - posted by "Phixsura (via GitHub)" <gi...@apache.org> on 2026/05/21 15:51:13 UTC, 1 replies.
- [PR] MINOR: Provide default no-op implementations for addReconfigurable and removeReconfigurable in AbstractKafkaConfig [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/21 15:55:41 UTC, 4 replies.
- [PR] KAFKA-17689: Migrate ReassignReplicaMoveTest and ReassignReplicaExpandTest to new test infra [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/21 16:50:02 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-14276) Clarify java doc for ProcessorAPI init method and stateStore.approximateNumEntries() - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/05/21 18:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-18157) Consider UnsupportedVersionException child class to represent the case of unsupported fields - posted by "Alan Lau (Jira)" <ji...@apache.org> on 2026/05/21 18:22:00 UTC, 0 replies.
- [PR] MINOR: extracted the majority of the logic from MemoryRecordsBuilder to an abstract class. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/21 21:04:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20526) Add ListClientConnections Admin API to list authenticated connections on brokers - posted by "Mehari Beyene (Jira)" <ji...@apache.org> on 2026/05/21 23:29:00 UTC, 0 replies.
- [PR] KAFKA-15038: Remove topicIdByPartitionMap from RemoteLogManager [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/22 00:18:25 UTC, 2 replies.
- Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/22 04:51:18 UTC, 1 replies.
- [PR] MINOR: Move inter-broker NetworkClient factory to server module [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/22 05:53:07 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-19893) Reduce tiered storage redundancy with delayed upload - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/05/22 08:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-19893) Reduce tiered storage redundancy with delayed upload - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/05/22 08:26:00 UTC, 0 replies.
- [PR] MINOR: Reduce close delay in testFailureToFenceEpoch [kafka] - posted by "JiayaoS (via GitHub)" <gi...@apache.org> on 2026/05/22 10:23:46 UTC, 3 replies.
- [PR] MINOR: Correct the variable name related to remote delay storage in the test [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/05/22 11:16:18 UTC, 1 replies.
- [PR] MINOR: Correct the variable name in remote storage's test [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/05/22 11:39:02 UTC, 5 replies.
- Re: [PR] KAFKA-20128: Add missing TimestampType to java doc and move non-public classes to internal subpackage [kafka] - posted by "mr-git (via GitHub)" <gi...@apache.org> on 2026/05/22 11:46:39 UTC, 4 replies.
- [jira] [Commented] (KAFKA-20602) DLQ topic creation has 3 issues: indefinite hang, wrong log level, interrupt not restored - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/22 15:13:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-20602) DLQ topic creation has 3 issues: indefinite hang, wrong log level, interrupt not restored - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/22 15:13:00 UTC, 0 replies.
- [PR] MINOR: Split GroupMetadataManagerTest into per-group-type files [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2026/05/22 17:53:29 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20070) Evaluate and define the reasonable upper bounds for share.coordinator.snapshot.update.records.per.snapshot - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/22 19:29:00 UTC, 0 replies.
- [PR] MINOR: Added Compression.wrapForInput method for ByteBufferInputStream. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/22 19:59:36 UTC, 1 replies.
- [jira] [Created] (KAFKA-20603) Replace MemoryLRUCache restoring flag with restore lifecycle hooks - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/22 22:12:00 UTC, 0 replies.
- Re: [PR] KAFKA-17928: Make remote log manager thread-pool configs dynamic [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/23 02:31:17 UTC, 1 replies.
- Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/23 04:45:29 UTC, 1 replies.
- Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/23 04:45:30 UTC, 1 replies.
- [PR] MINOR: Fix typo in DynamicBrokerConfigTest [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/23 05:20:37 UTC, 3 replies.
- [PR] MINOR: Move DynamicLogConfig to server module [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/23 06:08:14 UTC, 1 replies.
- [PR] Don't Merge [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/23 07:52:14 UTC, 1 replies.
- [PR] For test auto reviewer. [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/23 08:02:44 UTC, 3 replies.
- Re: [PR] MINOR: Don't Merge this [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/23 10:48:07 UTC, 0 replies.
- Re: [PR] MINOR: For test auto reviewer [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/23 11:15:18 UTC, 1 replies.
- [jira] [Commented] (KAFKA-19298) Move RuntimeLoggerManager to server module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/23 14:26:00 UTC, 1 replies.
- [PR] KAFKA-20601: Allow static member rejoin when consumer group is full. [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/23 14:56:13 UTC, 12 replies.
- [PR] KAFKA-19883: KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/05/23 18:19:19 UTC, 17 replies.
- [PR] Fix typo 'amd' -> 'and' in CompletableEventReaperTest comments [kafka] - posted by "RonGamzu (via GitHub)" <gi...@apache.org> on 2026/05/23 19:12:20 UTC, 2 replies.
- [PR] Fix typo 'instantiater' -> 'instantiator' in LeaderEpochFileCache Javadoc [kafka] - posted by "RonGamzu (via GitHub)" <gi...@apache.org> on 2026/05/23 19:12:22 UTC, 2 replies.
- [PR] MINOR: Add hearbeat interval override to PerformanceServiceTest [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/23 20:01:45 UTC, 1 replies.
- [PR] KAFKA-17689: Migrate TieredStorageTestHarness to new test infra [kafka] - posted by "TaiJuWu (via GitHub)" <gi...@apache.org> on 2026/05/24 01:55:06 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-19298) Move RuntimeLoggerManager to server module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/24 03:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20604) KIP-1348: Complete Built-in Exception Handler Symmetry with LogAndContinueProductionExceptionHandler - posted by "Ankur Sinha (Jira)" <ji...@apache.org> on 2026/05/24 04:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20604) KIP-1348: Complete Built-in Exception Handler Symmetry with LogAndContinueProductionExceptionHandler - posted by "Ankur Sinha (Jira)" <ji...@apache.org> on 2026/05/24 04:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20604) KIP-1348: Complete Built-in Exception Handler Symmetry with LogAndContinueProductionExceptionHandler - posted by "Ankur Sinha (Jira)" <ji...@apache.org> on 2026/05/24 04:34:00 UTC, 3 replies.
- Re: [PR] DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 04:53:18 UTC, 0 replies.
- Re: [PR] KAFKA-20189: Add character class support to GlobComponent [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/24 04:53:23 UTC, 1 replies.
- Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/24 08:19:19 UTC, 7 replies.
- [jira] [Created] (KAFKA-20605) upgrade gradle action to enable the CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/24 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20605) upgrade gradle action to enable the CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/24 13:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20605) upgrade gradle action to enable the CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/24 13:49:00 UTC, 0 replies.
- [PR] KAFKA-20605 upgrade gradle action to enable the CI [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/24 13:50:50 UTC, 1 replies.
- [PR] MINOR:MINOR: Narrow remote copy lag validator props to Map [kafka] - posted by "jiafu1115 (via GitHub)" <gi...@apache.org> on 2026/05/24 13:54:37 UTC, 0 replies.
- [PR] KAFKA-20423: Fix flakiness of testWakeupWithFetchDataAvailable [kafka] - posted by "chickenchickenlove (via GitHub)" <gi...@apache.org> on 2026/05/24 14:52:40 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-20605) upgrade gradle action to enable the CI - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/24 15:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) [kafka] - posted by "Shekharrajak (via GitHub)" <gi...@apache.org> on 2026/05/24 15:13:15 UTC, 2 replies.
- [PR] KAFKA-20549: Implemented PRODUCE RPC handler for DLQ state manager. [5/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/24 18:30:12 UTC, 7 replies.
- [PR] KAFKA-20603 : Replace MemoryLRUCache restoring flag with restore lifecycle hooks [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/24 20:02:31 UTC, 3 replies.
- Re: [PR] KAFKA-16799: Reduce log level for 'Node is not ready' message to TRACE [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:02:25 UTC, 0 replies.
- Re: [PR] KAFKA-20097: Populate topicId for existing topics in CreateTopics response [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:02:28 UTC, 0 replies.
- Re: [PR] KAFKA-10731: Add support for SSL hot reload [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/25 05:02:32 UTC, 1 replies.
- [PR] Feat: Hardening MirrorMaker 2 Replication Pipeline with Truncation Recovery [kafka] - posted by "rajabhishekmaurya (via GitHub)" <gi...@apache.org> on 2026/05/25 07:25:48 UTC, 1 replies.
- [jira] [Created] (KAFKA-20606) Using a Map to replace Properties in the configuration propagation flow - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/25 07:50: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 "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/25 08:05:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20607) Include _index.md in version checks - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/25 09:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20607) the version examine should include _index.md file - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/25 09:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20607) Include _index.md in version checks - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/25 10:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20608) classic consumer static member rejoin can fail with GroupMaxSizeReachedException at max size - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/25 12:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20524) Initialization of share group offsets from a specific offset or a file - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2026/05/25 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20535) Investigate potential improvements to async consumer CPU usage under low max.poll.records - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/25 18:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20535) Investigate potential improvements to async consumer CPU usage under low max.poll.records - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2026/05/25 18:09:00 UTC, 0 replies.
- [PR] KAFKA-17689 Migrate TieredStorageTestHarness to new test infra (ListOffsetsTest) [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/26 01:59:50 UTC, 3 replies.
- Re: [PR] Support DynamicListenerConfig on controller [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/26 04:52:10 UTC, 1 replies.
- Re: [PR] KAFKA-8958 : Fix Kafka Streams JavaDocs with regard to used Serdes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/26 04:52:14 UTC, 0 replies.
- Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/26 04:52:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage - posted by "Manan Gupta (Jira)" <ji...@apache.org> on 2026/05/26 05:53:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20609) Use the lastModifiedTime to replace furture timestamp in deleting retentions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/26 06:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20609) Use the lastModifiedTime to replace furture timestamp in deleting retentions - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/26 06:35:00 UTC, 0 replies.
- [PR] KAFKA-17689: Migrate DeleteTopicTest to to new test infra [kafka] - posted by "joshua2519 (via GitHub)" <gi...@apache.org> on 2026/05/26 07:16:52 UTC, 3 replies.
- [jira] [Commented] (KAFKA-19584) Native docker image authentication fails with SASL PLAIN - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2026/05/26 07:35:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20610) Abstract ReplicaManager dependency from SharePartition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2026/05/26 07:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20612) Share group DLQ metrics - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/26 08:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20611) Integration of dlq manager with QFK code - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/26 08:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20613) Copy original record data in DLQ records - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/26 08:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20613) Copy records in DLQ records - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2026/05/26 08:49:00 UTC, 0 replies.
- [PR] KAFKA-17689: Add tiered storage test plan [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/26 09:19:04 UTC, 0 replies.
- [PR] KAFKA-20611: Stitch share group DLQ manager with the main code. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/26 09:31:04 UTC, 3 replies.
- [jira] [Created] (KAFKA-20614) KIP-1351: Add --cancel-all to kafka-reassign-partitions - posted by "Manan Gupta (Jira)" <ji...@apache.org> on 2026/05/26 10:38:00 UTC, 0 replies.
- [PR] MINOR: Add 4.3.0 to system tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/26 12:04:26 UTC, 7 replies.
- [jira] [Updated] (KAFKA-20532) Defensive trimming of min.insync.replicas in controller and kafka-topics to tolerate whitespace-contaminated configs - posted by "Sahil Devgon (Jira)" <ji...@apache.org> on 2026/05/26 13:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20223) Extended I/O Metrics Collection - posted by "Sahil Devgon (Jira)" <ji...@apache.org> on 2026/05/26 13:33:00 UTC, 0 replies.
- [PR] MINOR: Remove outdated note for streams group protocol [kafka] - posted by "UladzislauBlok (via GitHub)" <gi...@apache.org> on 2026/05/26 13:57:01 UTC, 4 replies.
- [PR] KAFKA-20394: Close stale broker connections when host or resolved IP changes [kafka] - posted by "gomudayya (via GitHub)" <gi...@apache.org> on 2026/05/26 14:48:57 UTC, 0 replies.
- [PR] KAFKA-17689: Migrate ReassignReplicaShrinkTest and RollAndOffloadActiveSegmentTest to new test infra [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/05/26 16:09:56 UTC, 1 replies.
- [PR] KAFKA-17689: Migrate {Disable,Enable}RemoteLogOnTopicTest to to new test infra [kafka] - posted by "johnny94 (via GitHub)" <gi...@apache.org> on 2026/05/26 16:37:38 UTC, 0 replies.
- [jira] [Created] (KAFKA-20615) Benchmark restore-path pause-resume toggle frequency to evaluate a lower resume threshold - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/26 19:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20616) Close-path leaks in RocksDBStore cause native memory growth that eventually leads to OOM - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/26 19:59:00 UTC, 0 replies.
- [PR] KAFKA-20616: Close offsets-CF ColumnFamilyOptions and ensure CF handles are releas… [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/26 20:11:51 UTC, 5 replies.
- [jira] [Updated] (KAFKA-20616) Close-path leaks in RocksDBStore cause native memory growth that eventually leads to OOM - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/26 20:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16876) TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit - posted by "Ziyun Fu (Jira)" <ji...@apache.org> on 2026/05/26 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 00:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20259) Verify IQv1 and IQv2 does not break - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 00:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20422) Add DSL integration tests for header stores with explicit suppliers - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 00:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20329) Test `headers` dsl.store.format further - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 00:29:00 UTC, 0 replies.
- [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/05/27 00:41:59 UTC, 0 replies.
- Re: [PR] MINOR: Caching immutable voterKeys [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 04:35:49 UTC, 0 replies.
- Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/27 04:59:46 UTC, 0 replies.
- [PR] MINOR: MM2 surface log-truncation and topic-reset as actionable events in MirrorSourceTask [kafka] - posted by "rajabhishekmaurya (via GitHub)" <gi...@apache.org> on 2026/05/27 07:00:18 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20615) Benchmark restore-path pause-resume toggle frequency to evaluate a lower resume threshold - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/27 08:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20590) Add integration test coverage for restore.buffered.records.per.partition cap - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/27 08:35:00 UTC, 0 replies.
- [PR] MINOR: Add 4.3.0 to core system tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/27 09:45:30 UTC, 1 replies.
- [PR] KAFKA-20612: Add DLQ related metrics to ShareGroupMetrics. [1/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/27 09:50:47 UTC, 3 replies.
- [jira] [Created] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2026/05/27 10:21:00 UTC, 0 replies.
- [PR] MINOR: Add 4.2.0 and 4.3.0 to streams system tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/27 10:34:43 UTC, 3 replies.
- [PR] KAFKA-20617: add validation for cluster-id in Formatter [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2026/05/27 10:48:54 UTC, 9 replies.
- [PR] KAFKA-20549: ReplicaManager method wrapper to read records in share group DLQ. [6/N] [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/27 10:54:32 UTC, 3 replies.
- [jira] [Created] (KAFKA-20618) Streams Group Topology Description Plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 13:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20618) Streams Group Topology Description Plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 13:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20618) Streams Group Topology Description Plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 13:13:00 UTC, 2 replies.
- Re: [PR] KAFKA-18972: Use custom processor during read-only state store restoration [kafka] - posted by "Copilot (via GitHub)" <gi...@apache.org> on 2026/05/27 13:59:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-20619) ClusterTests may report Thread leak detected: Cleaner-0, Cleaner-1 - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/05/27 14:10:00 UTC, 0 replies.
- [PR] KAFKA-20619: ClusterTestExtensions skip jdk.internal.ref.CleanerImpl … [kafka] - posted by "edoardocomar (via GitHub)" <gi...@apache.org> on 2026/05/27 14:34:04 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20619) ClusterTests may report Thread leak detected: Cleaner-0, Cleaner-1 - posted by "Edoardo Comar (Jira)" <ji...@apache.org> on 2026/05/27 14:37:00 UTC, 0 replies.
- [PR] [PoC] KIP-1128: Replace KTable.transformValues with KTable.processFixedKey and add new KStreams.processFixedKey [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/05/27 15:06:04 UTC, 0 replies.
- Re: [PR] KAFKA-17689 Migrate Disable/EnableRemoteLogOnTopicTest to new test infra [kafka] - posted by "chia7712 (via GitHub)" <gi...@apache.org> on 2026/05/27 15:13:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-17871) Source task source offset reads can block herder task cancellation - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/05/27 15:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-17871) Source task source offset reads can block herder task cancellation - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2026/05/27 15:29:00 UTC, 0 replies.
- Re: [PR] [DO-NOT-MERGE] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (2/N) [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2026/05/27 15:31:57 UTC, 0 replies.
- [PR] MINOR: Append reviewer trailer from issue_comment instead of pull_request_review [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/05/27 15:58:12 UTC, 1 replies.
- [jira] [Created] (KAFKA-20620) Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20620) Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:15:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20621) Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20621) Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20620) Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:15:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20621) Add StoredTopologyEpoch and LastFailedTopologyEpoch to StreamsGroup model and metadata record - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20622) Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20622) Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20622) Define StreamsGroupTopologyDescriptionPlugin SPI and InMemoryTopologyDescriptionPlugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20623) Wire topology description plugin into GroupCoordinatorService - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:18:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20624) Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:18:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:19:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20627) Add broker integration tests for topology description plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20627) Add broker integration tests for topology description plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20627) Add broker integration tests for topology description plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20629) Add ducktape system tests for topology description plugin - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20630) Add documentation for topology description plugin feature - posted by "Alieh Saeedi (Jira)" <ji...@apache.org> on 2026/05/27 16:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-19648; Cluster metadata bootstrapping with kraft checkpoint [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/27 16:25:57 UTC, 6 replies.
- [PR] KAFKA-20610: Added abstraction classes for share fetch reads (1/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/27 16:26:15 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-19648) KIP-1170: Unify cluster metadata bootstrapping - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/27 16:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20630) Add documentation for topology description plugin feature - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 16:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20629) Add ducktape system tests for topology description plugin - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 16:45:00 UTC, 0 replies.
- [PR] KAFKA-20628 Add TTL-based expiration to PartitionLeaderCache [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2026/05/27 16:48:31 UTC, 0 replies.
- [jira] [Created] (KAFKA-20631) Add "logical clients" concept - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 17:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/27 17:02:00 UTC, 1 replies.
- [PR] KAFKA-20607: Include _index.md in version consistency checks and updates [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/27 17:36:31 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-20631) Add "logical clients" concept - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2026/05/27 17:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20632) Code preparation and refactoring - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/27 18:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20632) Code preparation and refactoring - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/27 18:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20632) Code preparation and refactoring - posted by "Nikita Shupletsov (Jira)" <ji...@apache.org> on 2026/05/27 18:27:00 UTC, 0 replies.
- [PR] KAFKA-20632: Added ChunkedBufferPool that can allocate multiple byte buffers at once. [kafka] - posted by "Nikita-Shupletsov (via GitHub)" <gi...@apache.org> on 2026/05/27 20:38:59 UTC, 0 replies.
- Re: [PR] Kafka 18913/cleanup state updater on failure [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:56:14 UTC, 1 replies.
- Re: [PR] KAFKA-7516: Attempt to dynamically load ManagementFactory [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:56:15 UTC, 1 replies.
- Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/28 04:56:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/05/28 07:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20167) Introduce CloseOptions.DEFAULT for Kafka Streams - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2026/05/28 07:51:00 UTC, 0 replies.
- [PR] KIP-1331: Streams Group Topology Description Plugin (POC) [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/05/28 08:51:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-20633) Update the default value of remote copy lag bytes - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/05/28 09:11:00 UTC, 0 replies.
- [PR] KAFKA-20633: Update the default value of remote copy lag bytes [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2026/05/28 09:14:28 UTC, 1 replies.
- [jira] [Updated] (KAFKA-20633) Update the default value of remote copy lag bytes - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/05/28 09:15:00 UTC, 1 replies.
- [PR] KAFKA-17687: Migrate DeleteSegmentsDueToLogStartOffsetBreachTest to new test infra [kafka] - posted by "frankvicky (via GitHub)" <gi...@apache.org> on 2026/05/28 09:15:14 UTC, 2 replies.
- [PR] KAFKA-17689 Migrate OffloadAndConsumeFromLeaderTest and OffloadAndTxnConsumeFromLeaderTest to new test infra [kafka] - posted by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/05/28 09:23:20 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-18138) The controller must add all extant brokers to BrokerHeartbeatTracker when activating - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2026/05/28 09:56:00 UTC, 0 replies.
- [PR] KAFKA-20620: Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2026/05/28 10:14:31 UTC, 1 replies.
- [PR] MINOR: A starting point for a formal security model [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2026/05/28 10:23:13 UTC, 7 replies.
- Re: [PR] KAFKA-20607: Include docs in version consistency checks and updates [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/28 12:06:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-20634) Spurious HighWatermarkUpdate failed errors in the group coordinator after partition leadership change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/05/28 12:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20635) Spurious "Writing records..." failed errors in the group coordinator after partition leadership change - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/05/28 12:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20636) Use StreamsTopicFixture for the existing test cases in GroupMetadataManagerTest - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/28 12:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20636) Refactor Group Metadata Tests to Use Static Streams Group Fixtures and Helpers - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/28 12:51:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Roland Sommer (Jira)" <ji...@apache.org> on 2026/05/28 13:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20295) Removed controllers still in metadata, blocking finalizing upgrade to 4.2.0 - posted by "Roland Sommer (Jira)" <ji...@apache.org> on 2026/05/28 13:25:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-20547) Streams produces duplicates with EOS_v2 - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/28 14:07:00 UTC, 0 replies.
- [PR] MINOR:Add 4.2.1 to docker_scan workflow [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/28 15:11:30 UTC, 0 replies.
- [PR] KAFKA-17689 : Migrate FetchFromLeaderWithCorruptedCheckpointTest and PartitionsExpandTest [kafka] - posted by "muralibasani (via GitHub)" <gi...@apache.org> on 2026/05/28 16:23:31 UTC, 1 replies.
- [PR] KAFKA-19298: Move RuntimeLoggerManager to server module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/28 16:24:15 UTC, 1 replies.
- [PR] MINOR: Move LoggingController log level resolution test to server [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/28 17:41:00 UTC, 0 replies.
- [PR] KAFKA-17840: Move ClientRequestQuotaManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/28 17:51:27 UTC, 0 replies.
- [PR] MINOR: Document KAFKA-20616 native memory leak in 4.3.0 upgrade guideMessage for issue with 4.3 RocksDB native memory [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/28 18:14:31 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-10884) Limit the size of Fetch and FetchSnapshot response based on broker configuration - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/28 18:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-10884) Limit the size of Fetch and FetchSnapshot response based on broker configuration - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/28 18:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-10884) Limit the size of Fetch and FetchSnapshot response based on broker configuration - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2026/05/28 18:35:00 UTC, 0 replies.
- [PR] KAFKA-18157: Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] - posted by "alanlau28 (via GitHub)" <gi...@apache.org> on 2026/05/28 18:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20637) Move ForwardingManager to server module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/28 20:17:00 UTC, 0 replies.
- [PR] MINOR: fix class name in test tag & warns [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2026/05/28 20:44:28 UTC, 1 replies.
- [PR] KAFKA-20610: Wire abstraction interfaces into share group classes (2/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/28 21:54:15 UTC, 1 replies.
- Re: [PR] MINOR: Document KAFKA-20616 native memory leak in 4.3.0 upgrade guideMessage for issue with 4.3 RocksDB native memory [kafka] - posted by "bbejeck (via GitHub)" <gi...@apache.org> on 2026/05/28 21:57:28 UTC, 2 replies.
- Re: [PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2026/05/28 21:57:55 UTC, 1 replies.
- [jira] [Commented] (KAFKA-20100) Fix broken links in Developer Guide - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2026/05/28 22:01:00 UTC, 1 replies.
- [PR] KAFKA-20637: Move ForwardingManager to server module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/28 22:19:30 UTC, 0 replies.
- [jira] [Created] (KAFKA-20638) se Locale.ROOT in ConsumerGroupCommand.toLowerCase() - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/29 02:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2026/05/29 02:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20638) se Locale.ROOT in ConsumerGroupCommand.toLowerCase() - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/29 02:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20638) Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/29 02:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20638) Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/29 02:54:00 UTC, 0 replies.
- [PR] MINOR: Add generic config type to BrokerReconfigurable [kafka] - posted by "unknowntpo (via GitHub)" <gi...@apache.org> on 2026/05/29 03:38:24 UTC, 1 replies.
- Re: [PR] KAFKA-967 Use key range in ProducerPerformance [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:34:24 UTC, 0 replies.
- Re: [PR] KAFKA-1194: changes needed to run on Windows [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:57:24 UTC, 1 replies.
- Re: [PR] Add KafkaTopicCalculator feature [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:57:30 UTC, 1 replies.
- Re: [PR] Feature/grade [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:57:32 UTC, 1 replies.
- Re: [PR] MINOR: Enhance README with improved Kafka description [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/29 04:57:35 UTC, 1 replies.
- [PR] KAFKA-19536: Respect grace period for out-of-order stream joins [kafka] - posted by "goutamadwant (via GitHub)" <gi...@apache.org> on 2026/05/29 05:44:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-20639) Move EnvelopeUtils to server module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/29 07:24:00 UTC, 0 replies.
- [PR] MINOR: Move dlq code to server module. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/29 07:37:57 UTC, 1 replies.
- Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] - posted by "jsancio (via GitHub)" <gi...@apache.org> on 2026/05/29 09:18:29 UTC, 3 replies.
- [PR] KAFKA-20612: Stitch DLQ metrics with ShareGroupDLQStateManager. [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2026/05/29 12:05:04 UTC, 0 replies.
- Re: [PR] KAFKA-20618: KIP-1331 Streams Group Topology Description Plugin (POC) [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2026/05/29 12:28:36 UTC, 3 replies.
- [PR] KAFKA-20610: Move abstraction instantiation to BrokerServer for share fetch (3/N) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2026/05/29 13:01:35 UTC, 1 replies.
- [jira] [Created] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled - posted by "David Jacot (Jira)" <ji...@apache.org> on 2026/05/29 13:18:00 UTC, 0 replies.
- [PR] KAFKA-20638: Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() [kafka] - posted by "KenanAdel (via GitHub)" <gi...@apache.org> on 2026/05/29 13:38:37 UTC, 2 replies.
- [jira] [Updated] (KAFKA-20641) ConsumerGroup should clean up the state when a static member temporarily leaves - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/29 14:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20641) ConsumerGroup should clean up the state when a static member temporarily leaves - posted by "sanghyeok An (Jira)" <ji...@apache.org> on 2026/05/29 14:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-19536) KStream-KStream leftJoin didn't consider gracePeriod for out-of-order records - posted by "Goutam Adwant (Jira)" <ji...@apache.org> on 2026/05/29 16:00:00 UTC, 0 replies.
- [PR] KAFKA-20639: Move EnvelopeUtils to server module [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/29 16:22:32 UTC, 2 replies.
- [jira] [Commented] (KAFKA-19404) Connect's plugin.path documentation does not match behavior - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/29 16:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19979) Improve Kafka Streams config files - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/29 16:55:00 UTC, 0 replies.
- [PR] KAFKA-10317: Global thread should honor shutdown signal during bootstrapping [kafka] - posted by "lucliu1108 (via GitHub)" <gi...@apache.org> on 2026/05/29 17:37:55 UTC, 3 replies.
- [jira] [Created] (KAFKA-20642) Support character ranges in Kafka shell globs - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/05/29 17:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20643) Share common implementation for downstream offset translation boundary in MirrorMaker offset syncs - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/05/30 03:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20643) Share common implementation for downstream offset translation boundary in MirrorMaker offset syncs - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/05/30 03:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20642) Support character ranges in Kafka shell globs - posted by "Jheng-Sing Chen (Jira)" <ji...@apache.org> on 2026/05/30 03:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-20638) Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/30 03:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) (WIP) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:26:56 UTC, 0 replies.
- Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:47:36 UTC, 0 replies.
- Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:47:38 UTC, 0 replies.
- Re: [PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:47:39 UTC, 0 replies.
- Re: [PR] MINOR: Add startup-duration logging to help with Kafka startup performance tuning [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:47:43 UTC, 0 replies.
- Re: [PR] KAFKA-19877: Clarify ByteBuffer position and limit expectations for Deserializer [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/30 04:47:47 UTC, 1 replies.
- [PR] MINOR: Write bootstrap checkpoint only to metadata directories [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/30 05:06:30 UTC, 2 replies.
- [PR] MINOR: Add 4.2.1 to upgrade.md [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/30 05:18:23 UTC, 2 replies.
- [PR] MINOR: remove stale zk comment [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/30 05:46:23 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" - posted by "Muralidhar Basani (Jira)" <ji...@apache.org> on 2026/05/30 06:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they matc - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 08:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they matc - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 08:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they matc - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 08:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they match - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 08:06:00 UTC, 3 replies.
- [PR] demo pr [kafka] - posted by "mubin-puc (via GitHub)" <gi...@apache.org> on 2026/05/30 13:41:08 UTC, 1 replies.
- [PR] MINOR: Add 4.2.1 to upgrade.md (#22419) [kafka] - posted by "FrankYang0529 (via GitHub)" <gi...@apache.org> on 2026/05/30 14:06:08 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-20602) DLQ topic creation has 3 issues: indefinite hang, wrong log level, interrupt not restored - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/05/30 14:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they match - posted by "Pavel Zeger (Jira)" <ji...@apache.org> on 2026/05/30 14:30:00 UTC, 0 replies.
- [PR] MINOR: Batch ExpiringErrorCache updates and cleanup [kafka] - posted by "brandboat (via GitHub)" <gi...@apache.org> on 2026/05/30 15:17:44 UTC, 0 replies.
- [PR] KAFKA-20602: Bound DLQ topic creation, fix log level and restore interrupt in DeadLetterQueueReporter Body: [kafka] - posted by "PavelZeger (via GitHub)" <gi...@apache.org> on 2026/05/30 15:59:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates - posted by "Aryan Gupta (Jira)" <ji...@apache.org> on 2026/05/30 16:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Aryan Gupta (Jira)" <ji...@apache.org> on 2026/05/30 17:25:00 UTC, 1 replies.
- [PR] KAFKA-18862: Consolidate shared heartbeat request manager tests [kafka] - posted by "nileshkumar3 (via GitHub)" <gi...@apache.org> on 2026/05/30 18:09:53 UTC, 0 replies.
- [jira] [Created] (KAFKA-20645) Move LogLoaderTest to storage module - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2026/05/30 18:29:00 UTC, 0 replies.
- [PR] KAFKA-20645: Move LogLoaderTest to storage module [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2026/05/30 19:35:50 UTC, 0 replies.
- [PR] Fix minor typos in CompletableEventReaperTest and LeaderEpochFileCache [kafka] - posted by "RonGamzu (via GitHub)" <gi...@apache.org> on 2026/05/30 23:48:37 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/31 00:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-20628) TimeoutException cascades in Connect due to PartitionLeaderCache stale entries - posted by "Hector Geraldino (Jira)" <ji...@apache.org> on 2026/05/31 00:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-20646) Use Locale.ROOT in String.format() calls in tools/ and server-common/ modules - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/31 02:32:00 UTC, 0 replies.
- [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka] - posted by "vanba4772 (via GitHub)" <gi...@apache.org> on 2026/05/31 02:46:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20646) Use Locale.ROOT in String.format() calls in tools/ and server-common/ modules - posted by "Basivi Vanga (Jira)" <ji...@apache.org> on 2026/05/31 02:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19818) Move ClientQuotaMetadataManager to metadata module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 02:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-19819) Move BrokerMetadataPublisher to metadata module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 03:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-18709) Move DynamicConfigPublisher to metadata module - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 03:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2026/05/31 04:48:00 UTC, 2 replies.
- Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/31 05:01:42 UTC, 0 replies.
- Re: [PR] KAFKA-14615: Use sizeCompare for collection size equality checks [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2026/05/31 05:01:48 UTC, 0 replies.
- [PR] MINOR: Note that formatted storage directories are not forward-compatible [kafka] - posted by "m1a2st (via GitHub)" <gi...@apache.org> on 2026/05/31 05:10:40 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 05:20:00 UTC, 0 replies.
- [PR] KAFKA-20642: Support character ranges in Kafka shell globs [kafka] - posted by "Russole (via GitHub)" <gi...@apache.org> on 2026/05/31 08:52:15 UTC, 1 replies.
- [jira] [Created] (KAFKA-20647) Add example for Queues for Kafka - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 09:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-20647) Add example for Queues for Kafka - posted by "majialong (Jira)" <ji...@apache.org> on 2026/05/31 09:17:00 UTC, 1 replies.
- [PR] Add draft threat model + SECURITY.md + AGENTS.md for security-model discoverability [kafka] - posted by "potiuk (via GitHub)" <gi...@apache.org> on 2026/05/31 10:18:19 UTC, 0 replies.
- [PR] KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner [kafka] - posted by "ivanyu (via GitHub)" <gi...@apache.org> on 2026/05/31 10:39:55 UTC, 0 replies.
- [PR] KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode [kafka] - posted by "ivanyu (via GitHub)" <gi...@apache.org> on 2026/05/31 10:40:47 UTC, 0 replies.
- [PR] KAFKA-19193: trace-log rack-specific load stats in rack-aware mode [kafka] - posted by "ivanyu (via GitHub)" <gi...@apache.org> on 2026/05/31 10:41:20 UTC, 0 replies.
- [PR] KAFKA-7493: Remove obsolete controller bounce-at-start Streams test [kafka] - posted by "majialoong (via GitHub)" <gi...@apache.org> on 2026/05/31 17:21:20 UTC, 1 replies.