AW: Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode

2022-05-17 Thread Florian Blumenstein
Hi Thomas, thanks for the quick answer. I got it running by declaring the CONTROLLER listerner also as SSL and using the existing keystore/trustore for it. Unfortunately I now recognize a new issue when restarting Kafka: https://issues.apache.org/jira/browse/KAFKA-13909 Hopefully this will als

kafka stream - sliding window - getting unexpected output

2022-05-17 Thread Shankar Mane
Hi All, Our use case is to use sliding window. (for e.g. at any point, whenever > user performs any actions at time [ t1 ], we would like to see his activity > in [ t1 - last 24 hours]. Using this, to show the user some recommendations. -- I have code ready and it works without any errors. -- a

[ANNOUNCE] Apache Kafka 3.2.0

2022-05-17 Thread Bruno Cadonna
The Apache Kafka community is pleased to announce the release for Apache Kafka 3.2.0 * log4j 1.x is replaced with reload4j (KAFKA-9366) * StandardAuthorizer for KRaft (KIP-801) * Send a hint to the partition leader to recover the partition (KIP-704) * Top-level error code field in DescribeLogDir

Re: [ANNOUNCE] Apache Kafka 3.2.0

2022-05-17 Thread Bill Bejeck
Thanks for running the release Bruno! On Tue, May 17, 2022 at 12:02 PM Bruno Cadonna wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 3.2.0 > > * log4j 1.x is replaced with reload4j (KAFKA-9366) > * StandardAuthorizer for KRaft (KIP-801) > * Send a hint t