Kafka

Hi, Following up with the test results: Unit/integration tests: https://github.com/apache/kafka/actions/runs/25053481746 System tests: Core: https://drive.google.com/file/d/1k7Vblxai4n1hV6mPlJ4O_Zp5zJx3OYuC/view?usp=sharing 1 failure: test_rate_device_name=eth0_latency_ms=50_metadata_quorum=COMBINED_KRAFT_rate_limit_kbit=1000000_task_name=rate-1000-latency-50 kafkatest.tests.core.network_degrade_test The test consistently fails in my environment Non Core: https://drive.google.com/file/d/16Fg7IcKOl5l3sbfcLjD08Wd6yWEP2ofx/view?usp=sharing 1 failure: test_replica_lags_metadata_quorum=ISOLATED_KRAFT kafkatest.tests.tools.replica_verification_test The test is flaky, it passed in a rerun. Thanks, Mickael On Tue, Apr 28, 2026 at 4:57 PM Mickael Maison <mickael.maison@gmail.com> wrote: > > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 4.3.0. > > This release includes ...

Congratulations Sean. On Thu, 30 Apr, 2026, 00:18 Chia-Ping Tsai, <chia7712@gmail.com> wrote: > The Project Management Committee (PMC) for Apache Kafka is pleased to > announce Sean Quah as a new Kafka committer. > > Sean is a true Kafka expert who has made numerous significant contributions > to the project. If you are amazed by the new consumer protocol, we owe a > huge thanks to Sean for helping build this foundational feature. Honestly, > I am so proud to be the one sharing this exciting news with you all. > > Please join me in welcoming and congratulating Sean! > > Chia-Ping Tsai > On behalf of the Apache Kafka PMC >

Congrats! On 4/29/26 12:39 PM, Lianet Magrans wrote: > Congratulations Sean!!! > > On Wed, Apr 29, 2026, 3:19 p.m. Mickael Maison <mickael.maison@gmail.com> > wrote: > >> Congratulations Sean! >> >> On Wed, Apr 29, 2026 at 9:05 PM Dongnuo Lyu via dev >> <dev@kafka.apache.org> wrote: >>> >>> Congrats Sean!! >> >

Congratulations Sean! On Wed, Apr 29, 2026 at 2:49 PM Chia-Ping Tsai <chia7712@gmail.com> wrote: > The Project Management Committee (PMC) for Apache Kafka is pleased to > announce Sean Quah as a new Kafka committer. > > Sean is a true Kafka expert who has made numerous significant contributions > to the project. If you are amazed by the new consumer protocol, we owe a > huge thanks to Sean for helping build this foundational feature. Honestly, > I am so proud to be the one sharing this exciting news with you all. > > Please join me in welcoming and congratulating Sean! > > Chia-Ping Tsai > On behalf of the Apache Kafka PMC >

Hello team, I have a question, your help would be greatly appreciated. KRaft: enabling ACLs + OAuth on an existing cluster required a full reformat, is this expected? Apache Kafka 3.9, KRaft mode, 3 nodes (combined controller+broker). Cluster originally formatted and running with no authorizer and PLAINTEXT only. Goal: add StandardAuthorizer + SASL_SSL/OAUTHBEARER without data loss. What I observed: after updating server.properties on all nodes (authorizer class, super.users, OAuth listener config) and rolling restart, the brokers came up but logs showed what looked like a state mismatch, controllers/brokers behaving as if part of them were still on the pre-change config (old listener names, missing principal context for inter-broker traffic). What worked: stop all nodes, wipe log.dirs and the metadata log, kafka-storage.sh format with the authorizer + OAuth config already in server.properties, start fresh. Clean cluster, ACLs and OAuth working immediately. Qu...

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 4.3.0. This release includes 25 KIPs bringing improvements to all components. Note that we still have 1 blocker (KAFKA-20441) so there will be another RC. Release notes for the 4.3.0 release: https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc0/RELEASE_NOTES.html Please download, test and vote by May 4, 5pm CEST Kafka's KEYS file containing PGP keys we use to sign the release: https://downloads.apache.org/kafka/KEYS * Release artifacts to be voted upon (source and binary): https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc0/ * Docker release artifacts to be voted upon: apache/kafka:4.3.0-rc0 apache/kafka-native:4.3.0-rc0 * Maven artifacts to be voted upon: https://repository.apache.org/content/groups/staging/org/apache/kafka/ * Javadoc: https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc0/javadoc/index.html * Tag to be voted upo...

Hi Lucas, This was indeed the issue, and your fix resolved it. Thanks for the assistance — greatly appreciated. Best, Yves. C2 - Restricted use ________________________________ Van: Lucas Brutschy via users <users@kafka.apache.org> Verzonden: maandag 27 april 2026 13:46 Aan: users@kafka.apache.org <users@kafka.apache.org> CC: Lucas Brutschy <lbrutschy@confluent.io> Onderwerp: Re: Kafka Streams 4.1.2 offsets not being committed after upgrade from Spring Boot 3.5.8 to 4.0.5 Hi Yves, do you use a consumer interceptor or wrapper that constructs ConsumerRecord objects using a deprecated pre-4.0 constructor? We have seen these problems when people use these kinds of outdated overloads; see https://eur01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fcwiki.apache.org%2Fconfluence%2Fdisplay%2FKAFKA%2FKIP-1094%253A%2BAdd%2Ba%2Bnew%2Bconstructor%2Bmethod%2Bwith%2BnextOffsets%2Bto%2BConsumerRecords&data=05%7C02%7Cyves.stroucken%40soprasteria.co...