Kafka

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...

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://cwiki.apache.org/confluence/display/KAFKA/KIP-1094%3A+Add+a+new+constructor+method+with+nextOffsets+to+ConsumerRecords. If that is the case, the solution is to use the new overload. Cheers, Lucas On Fri, Apr 24, 2026 at 5:58 PM STROUCKEN Yves <yves.stroucken@soprasteria.com> wrote: > > Hi Bill, > > Thanks for the quick reply. > Here is some of the output I get with debug logging and kafka-consumer-groups.sh > > ./kafka-consumer-groups.sh \ > --bootstrap-server localhost:9092 \ > --describe \ > --group 'MyProcessingApplication' > > loging.level.org.apache.kafka.streams.processor.internals.StreamTask: DEBUG > > Starting with a clean topic with no events. > > output: ...