dev  

Messages by Thread

• [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
• [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
• [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
• [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
  • Re: [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
  • Re: [DISCUSS] KIP-924 Code cleanup for streams partitions assignor KAFKA-16873 Naveen
• [jira] [Resolved] (KAFKA-20957) [CVE-2026-49844] [log4j-api] [2.25.4] Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20957) [CVE-2026-49844] [log4j-api] [2.25.4] Krishna Chidrawar (Jira)
• [jira] [Created] (KAFKA-20956) Remove hamcrest from org.apache.kafka.streams.examples package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20955) Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20954) Remove hamcrest from org.apache.kafka.streams.kstream.internals.foreignkeyjoin package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20953) Remove hamcrest from org.apache.kafka.streams.internals package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20952) Remove hamcrest from org.apache.kafka.streams.kstream package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20951) StreamsMetricsImpl retains duplicate sensor names when a sensor is removed and recreated chomingi (Jira)
• [jira] [Created] (KAFKA-20950) Remove hamcrest from org.apache.kafka.streams.state package Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20949) Remove hamcrest from org.apache.kafka.streams.query package Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20948) Migrate hamcrest tests to JUnit Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20947) ZkWriteSnapshotTimeMs metric reports negative values Michael Westerby (Jira)
• Community over Code Glasgow 2026 Hackathon - Action Needed Bowen, Rich
• [jira] [Created] (KAFKA-20946) Rewrite SaslPlaintextConsumerTest with dynamic sasl configurations Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20945) [CVE-2026-9828] , [ CVE-2026-10532] [logback-core] [1.5.25] Krishna Chidrawar (Jira)
• Minor consistency: subscribedTopicNames/regex bypass the DESCRIBE-TOPIC filter in ConsumerGroupDescribe/ShareGroupDescribe Mike Read
  • Re: Minor consistency: subscribedTopicNames/regex bypass the DESCRIBE-TOPIC filter in ConsumerGroupDescribe/ShareGroupDescribe David Jacot
  • Re: Minor consistency: subscribedTopicNames/regex bypass the DESCRIBE-TOPIC filter in ConsumerGroupDescribe/ShareGroupDescribe Andrew Schofield
• [jira] [Created] (KAFKA-20945) [CVE-2026-9828] [logback-core] [1.5.25] Krishna Chidrawar (Jira)
• Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #218 Apache Jenkins Server
• [jira] [Created] (KAFKA-20944) Add (E2E) tests for kafka-server-stop.sh Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20943) Upgrade Develocity related Gradle plugin versions Jira
• [jira] [Created] (KAFKA-20942) Refactor empty catch blocks in clients module tests to use assertThrows(). Kapil Hadoltikar (Jira)
• [jira] [Created] (KAFKA-20941) Replace HTMLTestRunner Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20813) docker_build_test.py doesn't like podman Chia-Ping Tsai (Jira)
• [Please approve GitHub workflow runs] Gradle build related PR's Dejan Stojadinović
• [PR] MINOR: Fix broken "Create documentation issue" link [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20940) Windowed changelog restore optimization is skipped whenever a checkpointed offset exists Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20939) Client applications broken by DNS resolution failure behaviour change Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-20936) Bump lz4 to 1.11.2 Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20682) Implement IQv2 for headers-aware state stores Jess Jin (Jira)
• [jira] [Resolved] (KAFKA-20852) buffer + doc PR Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20938) Previous JoinGroup/SyncGroup requests left dangling when retried Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20937) Bump lz4 to 1.11.2 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20937) Bump lz4 to 1.11.2 Jira
• [jira] [Created] (KAFKA-20936) Bump lz4 to 1.11.2 Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20935) Kafka: lz4-java ( CVE-2026-59949 ) Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20935) Kafka: lz4-java ( CVE-2026-59949 ) Krishna Chidrawar (Jira)
• [jira] [Resolved] (KAFKA-20931) Kraft network client doesn't handle certificate rotation Christo Lolov (Jira)
• [jira] [Resolved] (KAFKA-20929) ConnectStandaloneFileTest fails on FIPS-enabled systems due to MD5 usage Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20724) Topology pausing may have race condition Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20610) Abstract ReplicaManager dependency from SharePartition Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-20693) NPE in error handling in AbstractHerder Chia-Ping Tsai (Jira)
• Re: [SECURITY] Kafka Connect REST API — Unauthenticated Arbitrary File Read, SSRF, and Credential Theft via Default Configuration ASF Security
• [jira] [Resolved] (KAFKA-20618) Streams Group Topology Description Plugin Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20169) Support static membership for Kafka Streams with the streams rebalance protocol Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to 10.10.1 Matthias J. Sax (Jira)
• [VOTE] KIP-1362: Add a rollback-compatible storage format option for KRaft migration Anton Agestam via dev
  • Re: [VOTE] KIP-1362: Add a rollback-compatible storage format option for KRaft migration Muralidhar Basani via dev
  • Re: [VOTE] KIP-1362: Add a rollback-compatible storage format option for KRaft migration Gergely Harmadás
• [jira] [Resolved] (KAFKA-19902) Consumer triggers OFFSET_OUT_OF_RANGE when committed offset uses stale epoch after leader change Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20934) Considering Share Groups for decoupling stateless Kafka Streams processing parallelism from source partitions sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20933) RocksDBStore.putAll bypasses the transaction buffer Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20930) Make offload config private for 4.4 Sean Quah (Jira)
• [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Omnia Ibrahim
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Bill Bejeck
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Chia-Ping Tsai
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Chia-Ping Tsai
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 David Jacot
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Andrew Schofield
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Chia-Ping Tsai
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Andrew Schofield
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Matthias J. Sax
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Chia-Ping Tsai
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Mickael Maison
  • Re: [ANNOUNCE] Code freeze for Apache Kafka 4.4.0 Bill Bejeck
• [jira] [Created] (KAFKA-20932) RemoteLogLeaderEpochState loses replaced segments from leader epoch listings GiminKim (Jira)
• [jira] [Resolved] (KAFKA-20323) Refactor test method to enable Mockito version upgrade chomingi (Jira)
• [jira] [Resolved] (KAFKA-17754) A delayed EndTxn message can cause aborted read, lost writes, atomicity violation Justine Olshan (Jira)
• [jira] [Resolved] (KAFKA-16517) Do not decode metadata records in the internal kraft partition listener Jira
• [jira] [Resolved] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup Ziyun Fu (Jira)
• [jira] [Resolved] (KAFKA-20891) Mark unused "streams" protocol configs internal Matthias J. Sax (Jira)
• [Please provide `ci-approved` label] Gradle build releated PR's Dejan Stojadinović
• [jira] [Created] (KAFKA-20931) Kraft network client doesn't handle certificate rotation Christo Lolov (Jira)
• [jira] [Created] (KAFKA-20930) Make offload config private for 4.4 Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20409) Don't expose internal group configs unless they are user-defined. Sean Quah (Jira)
• [jira] [Reopened] (KAFKA-20036) Handle LogCleaner segment overflow caused by compression level changes Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20807) Refactor ByteBufferOutputStream for better extensibility Lianet Magrans (Jira)
• [PR] docs: update broken links in books and papers section [kafka-site] via GitHub
• [jira] [Created] (KAFKA-20929) ConnectStandaloneFileTest fails on FIPS-enabled systems due to MD5 usage Maros Orsak (Jira)
• [PR] KAFKA-20737: Add CI guard for archived release links [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." after a state updater remove times out during cold start rebalancing Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20757) Run store-level unit suites through the transactional path Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate() Nikita Shupletsov (Jira)
• [jira] [Resolved] (KAFKA-20711) Streams task restore-remaining-records metric never reaches 0 Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-14412) Transactional semantics for StateStores Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20502) Integration tests for IQv2 transaction isolation Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20927) Introduce new clientInstanceId method with no timeout and deprecate old methods Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20928) Remove deprecated clientInstanceId(Duration) methods in Apache Kafka 5.0 Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20926) Only send client ID and client instance ID on initial RPC on each connection Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20925) Introduce new versions of all other RPCs using request header v3 Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20924) Introduce request header version 3 in GetTelemetrySubscriptions and PushTelemetry RPCs Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20923) Introduce headerVersions into RPC schema definitions Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-20922) TimestampedRangeWithHeadersQuery iterator can NPE on a null-deserialized value (KV path missing the null guard the window path has) Jess Jin (Jira)
• [jira] [Resolved] (KAFKA-20915) Unneeded app thread wakeup when a fetch already in flight and nothing has changed in AsyncConsumer Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20921) ScramImage and ScramCredentialData are not deeply immutable GiminKim (Jira)
• [jira] [Created] (KAFKA-20920) Document new group coordinator executor metrics Sean Quah (Jira)
• [jira] [Created] (KAFKA-20919) Document KIP-1301 metrics changes Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20918) Add an example of RebalanceConsumer usage to the example module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20917) Improve RecordAccumulator.ready performance Xi Wang (Jira)
• [jira] [Created] (KAFKA-20916) message protocol document missing new control record types Jun Rao (Jira)
  • Re: [jira] [Created] (KAFKA-20916) message protocol document missing new control record types Yanko24
• [jira] [Resolved] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20915) Unneeded app thread wakeup when a fetch already in flight and nothing has changed in AsyncConsumer Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20914) KafkaRaftClient does not clear append/fetch purgatories when a leader transitions to Resigned or Unattached Anjaneya Gupta (Jira)
• [jira] [Created] (KAFKA-20913) KafkaRaftClient#appendBatch reads a recycled batch buffer in its async commit callback, producing an incorrect appendTimestamp for committed batches Anjaneya Gupta (Jira)
• [jira] [Created] (KAFKA-20912) Unhappy paths for non-replaying writes lead to divergence between in-memory state and log Sean Quah (Jira)
• [jira] [Created] (KAFKA-20911) CorruptRecordException: Found record size 0 smaller than minimum record overhead Santosh Kumar Sahu (Jira)
• [jira] [Created] (KAFKA-20910) alterShareGroupOffsets impl in GroupCoordinatorService does not follow the KIP-932 spec. Sushant Mahajan (Jira)
• [PR Review Request] KAFKA-20834: Add unit test for Bytes.toString() 이주호
• [jira] [Created] (KAFKA-20909) Consider bumping the consumer group epoch when a member's rack ID changes sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20908) Consider exposing RACK-ID in kafka-share-groups.sh sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20907) Remove deprecated 9-arg StreamsGroupDescription constructor Lucy Liu (Jira)
• [jira] [Created] (KAFKA-20906) Remove deprecated ValueJoinerWithKey overloads for stream-globalTable joins Lucy Liu (Jira)
• [jira] [Created] (KAFKA-20905) Remove deprecated headerless StreamPartitioner#partitions method Lucy Liu (Jira)
• [jira] [Created] (KAFKA-20904) AsyncKafkaConsumer is higher than expected CPU usage Evan Zhou (Jira)
• [jira] [Created] (KAFKA-20903) Revert public API changes from KIP-1238 Matthias J. Sax (Jira)
• [DISCUSS] KIP-789: Use localhost:9092 as default bootstrap-server/broker-list in client tools. ziming deng
• [jira] [Resolved] (KAFKA-20816) Add CIDR support also into Authorizer.authorizeByResourceType Mickael Maison (Jira)

• Earlier messages