dev  

Messages by Thread

• [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix typo in config name [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20522) Refine test coverage for consumer close-on-interrupt best-effort behavior Lianet Magrans (Jira)
• KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen
  • [DISCUSS] KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen
• [jira] [Created] (KAFKA-20708) KIP-1358: Gradual and gated preferred-leader election in the KRaft controller Haifeng Chen (Jira)
• [jira] [Resolved] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer Jheng-Sing Chen (Jira)
• [jira] [Created] (KAFKA-20707) Implement query type 5 (SessionKeyQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20706) Implement query type 4 (WindowRangeQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20704) Implement query type 2 (TimestampedRangeQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20705) Implement query type 3 (WindowKeyQueryWithHeaders) Jess Jin (Jira)
• [jira] [Created] (KAFKA-20701) KIP drafting, publication, discussion, vote Jess Jin (Jira)
• [jira] [Created] (KAFKA-20700) AllowedPaths should resolve symlinks before validating paths against allowed.paths Nilesh Kumar (Jira)
• [VOTE] KIP-1332: Dynamic memory allocation for the Kafka producer Lianet Magrans
  • Re: [VOTE] KIP-1332: Dynamic memory allocation for the Kafka producer Andrew Schofield
• [jira] [Created] (KAFKA-20699) TopologyTestDriver.getStateStore corrupts the task's record context Jira
• [jira] [Resolved] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing Andrew Schofield (Jira)
• [VOTE] 4.3.1 rc1 Bill Bejeck
• [jira] [Created] (KAFKA-20698) Remove deprecated ConsumerRecords(Map) constructor Evan Zhou (Jira)
• [PR] Bump hugo-extended from 0.161.1 to 0.163.2 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20697) Add cross-version system tests Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20696) Periodic plugin.deleteTopology cleanup for naturally-expired streams groups TengYao Chi (Jira)
• [jira] [Created] (KAFKA-20695) Extend "describe group" to return "task offset" metadata Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20637) Move ForwardingManager to server module Mickael Maison (Jira)
• [PR] MINOR: Update KAFKA-20254 migration bug note — fix now available in 4.2.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update KAFKA-20254 migration bug note — fix now available in 4.2.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing Shekhar Prasad Rajak (Jira)
• [jira] [Created] (KAFKA-20693) NPE in error handling in AbstractHerder Gaetan Collaud (Jira)
• [jira] [Resolved] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families Bill Bejeck (Jira)
• [PR] Add back negation that was lost in rewrite [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20692) Add unit tests for ToolsUtils Deepak Kumar S S (Jira)
• [jira] [Resolved] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n²) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line Shekhar Prasad Rajak (Jira)
• [jira] [Created] (KAFKA-20690) PersisterStateBatchCombinerTest silently skips 23 of 24 cases Shekhar Prasad Rajak (Jira)
• [jira] [Created] (KAFKA-20689) Remove unnecessary Hamcrest dependency from tools module Jheng-Sing Chen (Jira)
• [jira] [Resolved] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var Maros Orsak (Jira)
• [jira] [Resolved] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step Maros Orsak (Jira)
• [jira] [Created] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families Lucy Liu (Jira)
• [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.1 [kafka-site] via GitHub
• Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Matthias J. Sax
  • Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Manikumar
  • Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Andrew Schofield
  • Re: [VOTE] KIP-1265 : Mechanism for automatic detection of internal API usage Ashwin via dev
• [jira] [Created] (KAFKA-20687) Consider improving unused chunks reuse when no data written Lianet Magrans (Jira)
• Kafka Streams EOS: checkpoint file persists through RUNNING and skips the state wipe after unclean crash (4.1.2) esiva
  • Re: Kafka Streams EOS: checkpoint file persists through RUNNING and skips the state wipe after unclean crash (4.1.2) esiva
• [jira] [Resolved] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled David Jacot (Jira)
• [jira] [Reopened] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids Luke Chen (Jira)
• Subject: [VOTE] 4.3.1 RC0 Bill Bejeck
• [jira] [Created] (KAFKA-20686) DLQ integ tests Sushant Mahajan (Jira)
• [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Gabriella Fu via dev
  • Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups David Jacot
  • Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Gabriella Fu via dev
  • Re: [DISCUSS] KIP-1357: Add broker side custom assignors for "streams" groups Lucas Brutschy via dev
• [jira] [Created] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash Eswarar Siva (Jira)
• Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Luke Chen
  • Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Andrew Schofield
• RE: Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams Zhao, Guang via dev
• [jira] [Resolved] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20652) Improve/Fix java docs Jess Jin (Jira)
• [jira] [Resolved] (KAFKA-18862) Review testHeartbeatResponseOnErrorHandling duplicate logic in ShareHeartbeatRequestManagerTest Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20684) Add Deprecated anno for ConsumerRebalanceListener class/methods Aditya Kousik (Jira)
• [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Alieh Saeedi via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Matthias J. Sax
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Bill Bejeck
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Lucas Brutschy via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Alieh Saeedi via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Jess Jin via dev
  • Re: [DISCUSS] KIP-1356 Introduce IQv2 for headers-aware state stores Matthias J. Sax
• [jira] [Resolved] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench Lucy Liu (Jira)
• [jira] [Resolved] (KAFKA-20444) Align TxnOffsetCommit API with OffsetCommit API (KIP-1319) David Jacot (Jira)
• [jira] [Resolved] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics David Jacot (Jira)
• [jira] [Resolved] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20683) Add broker side custom assignors for "streams" groups Matthias J. Sax (Jira)
• [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.163.0 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20682) Implement IQv2 for headers-aware state stores Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20681) Consolidate heartbeat success path for consumer and shareConsumer Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20672) Handle ARCHIVING records in share partition initialize Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-20680) Prevent stale revocation state when Streams static member temporarily leaves sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20679) Remove deprecated Yammer-based group coordinator metrics Nick Guo (Jira)
• [jira] [Created] (KAFKA-20678) Analyze and impl fetch from remote storage for DLQ Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20677) Enhance the test coverage of testCannotSendToInternalTopic Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-14276) Clarify java doc for ProcessorAPI init method and stateStore.approximateNumEntries() Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20676) Broker fails to start when ssl.cipher.suites contains ciphers unavailable in the JSSE provider Jira
• [jira] [Created] (KAFKA-20675) Remove methods deprecated by KIP-1035 Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20674) Speed up ShareConsumerTest.testAcquisitionLockTimeoutOnConsumer Jheng-Sing Chen (Jira)
• [jira] [Created] (KAFKA-20673) AdminClient partition-leader APIs hang when a cached leader has left the cluster Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-20635) Spurious "Writing records..." failed errors in the group coordinator after partition leadership change David Jacot (Jira)
• [jira] [Resolved] (KAFKA-17689) Migrate TieredStorageTestHarness to new test infra Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20672) Handle ARCHIVING records in share partition initialize Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20671) Remove config `processing.exception.handler.global.enabled` Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20670) Remove kafka-streams-scala module Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20669) Fix Consumer propagates stale TopicAuthorizationException/InvalidTopicException after subscription change KC.H (Jira)
• [jira] [Resolved] (KAFKA-18209) Cleanup __transaction_state config logic Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18652) Extended set of streams-specific broker configurations Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20668) Add --checkpoint option to kafka-metadata-shell and deprecate --snapshot tony tang (Jira)
• [jira] [Created] (KAFKA-20667) O(N) ACL scan in StandardAuthorizerData.checkSection ibenchhida (Jira)
• [VOTE] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Matthias J. Sax
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Bill Bejeck
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Andrew Schofield
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Uladzislau Blok
  • Re: [VOTE] KIP-1321: Headers aware StreamPartitioner Matthias J. Sax
• [jira] [Created] (KAFKA-20666) Connect offset backing stores serialize ByteBuffer.array() instead of the buffer's remaining bytes Ruiqi Dong (Jira)
• [jira] [Created] (KAFKA-20665) Add warmup task support to reconciler Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20612) Share group DLQ metrics Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-20611) Integration of dlq manager with QFK code Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-20549) Implementation of Share Group DLQ Manager Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-20613) Copy original record data in DLQ records Sushant Mahajan (Jira)
  • [jira] [Resolved] (KAFKA-20613) Copy original record data in DLQ records Apoorv Mittal (Jira)
• [jira] [Reopened] (KAFKA-20613) Copy original record data in DLQ records Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20664) Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling Alan Lau (Jira)
• [jira] [Created] (KAFKA-20663) KIP-1035: stale persisted changelog offset causes OffsetOutOfRangeException/TaskCorruptedException on restart Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20662) Proper error code for malformed request during online migration Dongnuo Lyu (Jira)
• Re: 回复： [DISCUSS] KIP-1134: Virtual Clusters in Kafka Viktor Somogyi-Vass
  • Re: 回复： [DISCUSS] KIP-1134: Virtual Clusters in Kafka Andrew Schofield
• [jira] [Created] (KAFKA-20661) KRaft unavailability when controller are misconfigured Jira
• [DISCUSS] IllegalStateException from KafkaProducer.throwIfProducerClosed() — should it be a dedicated exception? Daulet Yeshmukhanbet
• [jira] [Created] (KAFKA-20660) Add guardrail to detect use of legacy ConsumerRecords constructor via nextOffsets() Evan Zhou (Jira)
• [jira] [Resolved] (KAFKA-20634) Spurious HighWatermarkUpdate failed errors in the group coordinator after partition leadership change David Jacot (Jira)
• [DISCUSS] KIP-1341: Replace <default> placeholder in ConfigEntity#name() with Optional<String> entityName() Ming-Yen Chung
• [jira] [Created] (KAFKA-20659) MirrorMaker Checkpoint and Heartbeat records can accept unsupported versions when assertions are disabled Ruiqi Dong (Jira)
• [jira] [Created] (KAFKA-20658) Cast SMT encodes ByteBuffer BYTES from index 0 instead of remaining bytes Ruiqi Dong (Jira)
• [jira] [Created] (KAFKA-20657) JsonConverter serializes ByteBuffer BYTES values using the backing array Ruiqi Dong (Jira)
• [jira] [Created] (KAFKA-20656) Struct BYTES handling does not normalize ByteBuffer values Ruiqi Dong (Jira)
• [jira] [Created] (KAFKA-20655) Mark KIP-1331 RPCs stable before release Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20654) Remove deprecated boolean-isTimestamped methods and the constructors in Dsl{KeyValue,Window,Session}Params Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20653) Remove deprecated headerless StateSerdes methods (keyFrom/valueFrom/rawKey/rawValue) Alieh Saeedi (Jira)
• [ANNOUNCE] Apache Kafka 4.2.1 PoAn Yang
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 sunil chaudhari
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Chia-Ping Tsai
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Lucas Brutschy via dev
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Christo Lolov
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 jian fu
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Jialong Ma
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 黃竣陽
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Nick Guo
  • Re: [ANNOUNCE] Apache Kafka 4.2.1 Andrew Schofield
• [PR] MINOR: Fix docker actions [kafka-site] via GitHub
• Request for JIRA Account Jess Jin via dev
  • Re: Request for JIRA Account Lianet Magrans
  • Re: Request for JIRA Account Lianet Magrans
• [PR] MINOR: Fix and add CVE-2026-41115 info [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix and add CVE-2026-41115 info [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix and add CVE-2026-41115 info [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix and add CVE-2026-41115 info [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix and add CVE-2026-41115 info [kafka-site] via GitHub
• CVE-2026-41115: Apache Kafka: Improper Authorization in CONSUMER_GROUP_DESCRIBE API Luke Chen
• [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sébastien Viale
  • Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Bill Bejeck
  • Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Lucas Brutschy via dev
  • Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Alieh Saeedi via dev
  • Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Matthias J. Sax
  • Re: [VOTE] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sébastien Viale
• [jira] [Created] (KAFKA-20652) Improve/Fix java docs Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20651) StandardAuthorizerData.checkSection infinite loop when ACL resource name is a prefix of the queried resource ibenchhida (Jira)
• [jira] [Created] (KAFKA-20650) In combined mode, BrokerServer and ControllerServer each independently called QuotaFactory.instantiate(), which created a separate ClientQuotaCallback instance via reflection for each role. Patrick Allen (Jira)
• Community over Code Glasgow 2026 Hackathon - Next Steps Bowen, Rich
• [jira] [Created] (KAFKA-20649) KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL Hannes Buseyne (Jira)
• [jira] [Created] (KAFKA-20648) Move Processor to server module Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19964) API Versions Response returns minimum metadata version for finalized level when no quorum exists Jira
• [jira] [Resolved] (KAFKA-20639) Move EnvelopeUtils to server module Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19528) Release script does not handle doing multiple release candidates Mickael Maison (Jira)
• [Vote] KIP-1326: Include broker static configurations in BrokerRegistrationRequest TaiJu Wu
  • Re: [Vote] KIP-1326: Include broker static configurations in BrokerRegistrationRequest Chia-Ping Tsai
• [jira] [Created] (KAFKA-20647) Add example for Queues for Kafka majialong (Jira)
• [jira] [Created] (KAFKA-20646) Use Locale.ROOT in String.format() calls in tools/ and server-common/ modules Basivi Vanga (Jira)
• [jira] [Created] (KAFKA-20645) Move LogLoaderTest to storage module Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20644) Connect’s RestServer assumes admin.listeners differ from listeners, silently orphaning admin resources when they matc Pavel Zeger (Jira)
• [PR] MINOR: Add 4.2.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add 4.2.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add 4.2.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: Add 4.2.1 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-20638) Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20643) Share common implementation for downstream offset translation boundary in MirrorMaker offset syncs Jheng-Sing Chen (Jira)
• [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.161.1 to 0.162.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20642) Support character ranges in Kafka shell globs Jheng-Sing Chen (Jira)
• [DISCUSS] Apache Kafka 4.3.1 release Bill Bejeck
• [jira] [Created] (KAFKA-20641) ConsumerGroup should clean up the state when a static member temporarily leaves sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled David Jacot (Jira)

• Earlier messages