dev  

Messages by Thread

• [jira] [Resolved] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3, 4.4 Justine Olshan (Jira)
• [jira] [Resolved] (KAFKA-21032) Please update kafka-clients.jar to address CVE-2026-59949 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21032) Please update kafka-clients.jar to address CVE-2026-59949 Joshua Wisniewski (Jira)
• [jira] [Resolved] (KAFKA-21002) Remove hamcrest from org.apache.kafka.streams package Ken Huang (Jira)
• [jira] [Created] (KAFKA-21031) Another busy loop happens while a heartbeat is in flight and the heartbeat timer is expired Eric Chang (Jira)
• [jira] [Created] (KAFKA-21030) Enhance the test coverage of CleanedTransactionMetadata Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21027) Remove hamcrest from org.apache.kafka.streams.integration package majialong (Jira)
• [jira] [Resolved] (KAFKA-21000) Potential data corruption on clean broker restart Jun Rao (Jira)
• [jira] [Created] (KAFKA-21028) Remove hamcrest from org.apache.kafka.streams.processor.internals package majialong (Jira)
• [jira] [Created] (KAFKA-21029) Remove hamcrest from org.apache.kafka.streams.state.internals package majialong (Jira)
• [jira] [Resolved] (KAFKA-20990) Remove hamcrest from org.apache.kafka.streams.integration.utils package Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20867) Upgrade RocksDB dependency from 10.1.3 to 10.10.1 Lucy Liu (Jira)
• [jira] [Resolved] (KAFKA-20970) Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms TengYao Chi (Jira)
• [jira] [Resolved] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20916) message protocol document missing new control record types Ken Huang (Jira)
• Jira account request pending review Seokmo Yoo
  • Re: Jira account request pending review Mickael Maison
• [jira] [Created] (KAFKA-21026) Design JHM benchmark for "refiner" Gavin Wang (Jira)
• [jira] [Created] (KAFKA-21025) StreamsGroupHeartbeatRequest.Builder does not clear owned warm-up tasks when it negotiates request version 0 Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20941) Replace HTMLTestRunner Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21024) WindowToTimestampedWindowByteStoreAdapter.query() does not convert results to timestamped format Ziyun Fu (Jira)
• [jira] [Created] (KAFKA-21023) Improve the usage of dependencycheck Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21022) Broker Crash During ZK-to-KRaft Migration Due to Missing Topic ID in Empty Log Directory Youssef Ismail (Jira)
• [PR REVIEW] KAFKA-20989: Add Notification Cleaners to Migrating Controller Servers Youssef Ismail via dev
• [DISCUSS] Apache Kafka 4.3.2 release 黃竣陽
  • Re: [DISCUSS] Apache Kafka 4.3.2 release Chia-Ping Tsai
  • Re: [DISCUSS] Apache Kafka 4.3.2 release 黃竣陽
• [jira] [Created] (KAFKA-21020) Fix CVE-2026-56740: Upgrade jline from 3.30.16 to 4.2.1 Shubhi Gupta (Jira)
• [jira] [Created] (KAFKA-21021) test_fencing_static_consumer is flaky for consumer protocol when duplicate static members do not start up at the same time. Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20952) Remove hamcrest from org.apache.kafka.streams.kstream package Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-20507) Clarify consumer docs around commits without metadata & invalid position handling TengYao Chi (Jira)
• [PR] KAFKA-21018: fix broken links [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21019) Cover consumer and share group protocols in docker sanity tests Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-1373: Client Quota Utilization Metrics Manan Gupta
• [jira] [Created] (KAFKA-21018) Broken links in Kafka docs and javadocs Jira
• [jira] [Created] (KAFKA-21017) Fix flaky ConsumerGroupCommandSaslAuthenticationTest Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21003) `testValidCreateTopicsRequests` should verify replica assignments of created topics Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21016) Add quota-utilization metric for client quotas Manan Gupta (Jira)
• [jira] [Created] (KAFKA-21015) Refactor producer control-record appends to use a single log append Hrishi Baskaran (Jira)
• [PR] Add dark and light mode support with system preference auto-detection [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21014) Fix flaky testAdminRebootstrapDisabled Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21013) Unable to dynamically update group.*.assignment.interval.ms configs with config providers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21012) Add integration tests for dynamic broker config updates using config providers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21011) kafka_2.13 marks kafka-server as a runtime rather than compile dependency which upsets kotlinc Robert Elliot (Jira)
• [jira] [Resolved] (KAFKA-19629) Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently TengYao Chi (Jira)
• [DISCUSS] Apache Kafka 4.2.2 release Apoorv Mittal
  • Re: [DISCUSS] Apache Kafka 4.2.2 release Bill Bejeck
  • Re: [DISCUSS] Apache Kafka 4.2.2 release Chia-Ping Tsai
  • Re: [DISCUSS] Apache Kafka 4.2.2 release Chia-Ping Tsai
  • Re: [DISCUSS] Apache Kafka 4.2.2 release Apoorv Mittal
• [jira] [Resolved] (KAFKA-20940) Windowed changelog restore optimization is skipped whenever a checkpointed offset exists Ken Huang (Jira)
• [DISCUSS] KAFKA-20776 MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() Naveen
• [jira] [Created] (KAFKA-21010) Another busy loop happens if the member is in JOINING state and bootstrap DNS resolution is not finished Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21004) [CVE-2026-68497][jackson-databind] Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21009) Consider introducing record header handling policies for Kafka Streams stateful operations sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21008) Consider allowing record headers to be filtered or masked before persistence in Kafka Streams state stores sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
• [jira] [Resolved] (KAFKA-20949) Remove hamcrest from org.apache.kafka.streams.query package Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout Justine Olshan (Jira)
• [jira] [Created] (KAFKA-21006) Migrate AbstractApiVersionsRequestTest, SaslApiVersionsRequestTest, ApiVersionsRequestTest to server module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21007) Migrate some test cases from KafkaRequestHandlerTest to BrokerTopicMetricsTest Chia-Ping Tsai (Jira)
• [DISCUSS] Release managers for 4.3.2 and 4.2.2 Chia-Ping Tsai
  • Re: [DISCUSS] Release managers for 4.3.2 and 4.2.2 PoAn Yang
  • Re: [DISCUSS] Release managers for 4.3.2 and 4.2.2 Apoorv Mittal
  • Re: [DISCUSS] Release managers for 4.3.2 and 4.2.2 Chia-Ping Tsai
  • Re: [DISCUSS] Release managers for 4.3.2 and 4.2.2 Apoorv Mittal
• [jira] [Created] (KAFKA-21005) Remove hamcrest from org.apache.kafka.streams.kstream.internals package majialong (Jira)
• [jira] [Created] (KAFKA-21004) [CVE-2026-68497][jackson-databind] Jira
• [jira] [Created] (KAFKA-21003) `testValidCreateTopicsRequests` should verify replica assignments of created topics Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21002) Remove hamcrest from org.apache.kafka.streams package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21001) Sticky assignor ("streams" protocol) ignores warm-up tasks for stickiness Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-21000) Potential data corruption on clean broker restart Jun Rao (Jira)
• [jira] [Created] (KAFKA-20999) Add rack-aware standby task assignment Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20920) Document new group coordinator executor metrics Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20997) Support running in FIPS environments Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20992) Remove hamcrest from org.apache.kafka.test package Hung-Yau Su (Jira)
• [jira] [Created] (KAFKA-20998) Add HA task assignor Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20882) Reduce build time: use lazy creation for Gradle tasks (i.e. use `tasks.register` instead of `task` or `tasks.create`) Jira
• [jira] [Resolved] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20996) `InetAddress.getHostName` could take long to impact network thread Luke Chen (Jira)
• [VOTE] KIP-1027: Add MockFixedKeyProcessorContext and TestFixedKeyRecordFactory Christopher Moyer
  • RE: [VOTE] KIP-1027: Add MockFixedKeyProcessorContext and TestFixedKeyRecordFactory niko
• [jira] [Created] (KAFKA-20995) [Draft][KIP-1371] Introduce a Consumer Reactor for state management and event processing Eric Chang (Jira)
• [jira] [Resolved] (KAFKA-20991) Remove hamcrest from org.apache.kafka.streams.internals package Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-20965) Remove hamcrest from org.apache.kafka.streams.state.internals.metrics package Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-20904) AsyncKafkaConsumer has higher than expected CPU usage Evan Zhou (Jira)
• [jira] [Resolved] (KAFKA-20314) Segmentation fault when starting kafka-native Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-1372: Reject topic configurations where min.insync.replicas exceeds the replication factor Zhisu Wang
• [jira] [Created] (KAFKA-20993) Remove org.apache.kafka.streams.processor.internals.assignment Jira
• [jira] [Resolved] (KAFKA-20950) Remove hamcrest from org.apache.kafka.streams.state package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20994) Speed up LeaderElectionCommandTest Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20990) Remove hamcrest from org.apache.kafka.streams.integration.utils package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20992) Remove hamcrest from org.apache.kafka.test package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20991) Remove hamcrest from org.apache.kafka.streams.internals package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20989) KRaft dual-write does not clean up ZooKeeper config and ACL notification znodes Youssef Ismail (Jira)
• [jira] [Resolved] (KAFKA-20982) The docker compose in isolation mode does not set the sasl listeners to all brokers Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-16245) DescribeConsumerGroupTest failing Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20988) Remove hamcrest from streams test fixtures Shantanu (Jira)
• [jira] [Created] (KAFKA-20987) Remove hamcrest from org.apache.kafka.streams.processor.internals.metrics package Shantanu (Jira)
• [jira] [Created] (KAFKA-20986) Speed up testDescribeConfigsNonexistent Chia-Ping Tsai (Jira)
• [REVIEW REQUEST] KAFKA-20977 — RemoteCopyLagSegments phantom lag on low-throughput tiered partitions Avishek Das
• [jira] [Resolved] (KAFKA-20983) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol Gavin Wang (Jira)
• [jira] [Resolved] (KAFKA-20984) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol Gavin Wang (Jira)
• [jira] [Created] (KAFKA-20985) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol Gavin Wang (Jira)
• [jira] [Created] (KAFKA-20984) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol Gavin Wang (Jira)
• [jira] [Created] (KAFKA-20983) Static consumer can be fenced by its own abandoned JoinGroup and crash with FencedInstanceIdException in classic protocol Gavin Wang (Jira)
• [jira] [Created] (KAFKA-20982) The docker compose in isolation mode does not set the sasl listeners to all brokers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20981) Kafka Streams should handle unknown status code pro-actively Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20955) Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20954) Remove hamcrest from org.apache.kafka.streams.kstream.internals.foreignkeyjoin package Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20689) Remove unnecessary Hamcrest dependency from tools module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay Ken Huang (Jira)
• Beam's new Kafka Streams runner: write KS applications in any Beam SDK Junaid
  • Re: Beam's new Kafka Streams runner: write KS applications in any Beam SDK Matthias J. Sax
  • Re: Beam's new Kafka Streams runner: write KS applications in any Beam SDK Matthias J. Sax
  • Re: Beam's new Kafka Streams runner: write KS applications in any Beam SDK Junaid
• [jira] [Resolved] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments) Avishek Das (Jira)
• [jira] [Created] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
• [PR] KAFKA-20974: Restore missing GitHub profile links in committers.json [kafka-site] via GitHub
  • Re: [PR] KAFKA-20974: Restore missing GitHub profile links in committers.json [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20975) Remove hamcrest from streams test-utils Shantanu Shukla (Jira)
• [ANNOUNCE] New committer: Jiunn-Yang Huang Chia-Ping Tsai
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang TengYao Chi
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang PoAn Yang
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Eric Chang
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Jie-Kai Chang
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Kamal Chandraprakash
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Andrew Schofield
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Maroš Orsák
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang jian fu
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Luke Chen
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Muralidhar Basani via dev
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Sanghyeok An
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Mickael Maison
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Rajini Sivaram
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Kuan-Po Tseng
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Sean Quah via dev
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang o . g . h . ibrahim
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang Matthias J. Sax
  • Re: [ANNOUNCE] New committer: Jiunn-Yang Huang 黃竣陽
• [jira] [Created] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) Chia-Ping Tsai (Jira)
• [PR] Added Jiunn-Yang Huang image and entry in committers.json [kafka-site] via GitHub
  • Re: [PR] Added Jiunn-Yang Huang image and entry in committers.json [kafka-site] via GitHub
• Review request: Gradle build improvements Dejan Stojadinović
• Re: [DISCUSS] KIP-1027 Add MockFixedKeyProcessorContext Christopher Moyer
• [VOTE] 4.4.0 RC0 Omnia Ibrahim
  • Re: [VOTE] 4.4.0 RC0 Andrew Schofield
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Omnia Ibrahim
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Mickael Maison
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Matthias J. Sax
  • Re: [VOTE] 4.4.0 RC0 Justine Olshan via dev
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC0 Justine Olshan via dev
• [PR] MINOR: Add 4.4 release [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-20865) Add check so voters cannot be unregistered Jun Rao (Jira)
• [jira] [Resolved] (KAFKA-20969) Mark "bootstrap.resolve.timeout.ms" as an experimental feature Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20973) Unable to dynamically update non string configs with config providers Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20972) Look into directly passing request paramaters instead of complete request in Share Coordinator Shard Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20971) Add cross version system test for "streams" static group membership Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20956) Remove hamcrest from org.apache.kafka.streams.examples package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20970) Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms Chia-Ping Tsai (Jira)
• Requesting review of submitted request for jira account - KAFKA Varshini
  • Re: Requesting review of submitted request for jira account - KAFKA Mickael Maison
• [jira] [Created] (KAFKA-20969) Mark "bootstrap.resolve.timeout.ms" as an experimental feature Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20968) Connect retry backoff overflows with infinite retries, dropping the delay to zero and restarting the exponential ramp sepuri sai krishna (Jira)
• [jira] [Resolved] (KAFKA-20919) Document KIP-1301 metrics changes Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20845) Consumer group downgrades can leave group in invalid state when classic group metadata is very large David Jacot (Jira)
• [jira] [Created] (KAFKA-20967) RemoteLogManager.read() leaks the remote segment InputStream when reading a batch fails sepuri sai krishna (Jira)
• [jira] [Created] (KAFKA-20966) RemoteLogInputStream can attempt an unbounded memory allocation when reading a corrupted remote log segment sepuri sai krishna (Jira)
• [jira] [Created] (KAFKA-20965) Remove hamcrest from org.apache.kafka.streams.state.internals.metrics package Kori H (Jira)
• [jira] [Resolved] (KAFKA-7345) Potentially unclosed FileChannel in StateDirectory#unlock Matthias J. Sax (Jira)
• [VOTE] KIP-1349 Bytes-based configurable snapshot frequency for share groups Muralidhar Basani via dev
• [jira] [Resolved] (KAFKA-16262) Add IQv2 to Kafka Streams documentation TengYao Chi (Jira)
• [jira] [Resolved] (KAFKA-20661) KRaft unavailability when controller are misconfigured Jira
• [jira] [Created] (KAFKA-20964) ScramParser flagged by security scanner Jira
• [jira] [Created] (KAFKA-20963) Remove hamcrest from org.apache.kafka.streams.processor Jira
• [jira] [Created] (KAFKA-20962) Remove hamcrest from org.apache.kafka.streams.kstream.internals.suppress Jira
• [jira] [Created] (KAFKA-20961) Loop of OffsetOutOfRangeException David Dufour (Jira)
• RE: Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client Frank Chi via dev
• [jira] [Created] (KAFKA-20960) Add controller-side check that brokers have re-registered with KRaft before finalizing ZK migration Kevin Wu (Jira)
• [jira] [Resolved] (KAFKA-17375) Partition reassignment cannot proceed after segment.bytes change Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20959) Blocked consumer using regex topic subscription Sean McNamara (Jira)
• [jira] [Resolved] (KAFKA-20939) Client applications broken by DNS resolution failure behaviour change TengYao Chi (Jira)
• [jira] [Resolved] (KAFKA-20758) Add lifecycle and recovery coverage Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20755) Extend transactional state store test coverage Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20958) Introduce internal accessor pattern to encapsulate cross-package APIs Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-924 Code cleanup for streams partitions assignor KAFKA-16873 Naveen
  • Re: [DISCUSS] KIP-924 Code cleanup for streams partitions assignor KAFKA-16873 Matthias J. Sax

• Earlier messages