Re: [ANNOUNCE] Apache Kafka 2.6.1

2021-01-11 Thread James Cheng
Thank you Mickael for running the release. Good job everyone! -James Sent from my iPhone > On Jan 11, 2021, at 2:17 PM, Mickael Maison wrote: > > The Apache Kafka community is pleased to announce the release for > Apache Kafka 2.6.1. > > This is a bug fix release and it includes fixes and

[ANNOUNCE] Apache Kafka 2.6.1

2021-01-11 Thread Mickael Maison
The Apache Kafka community is pleased to announce the release for Apache Kafka 2.6.1. This is a bug fix release and it includes fixes and improvements from 41 JIRAs, including a few critical bugs. All of the changes in this release can be found in the release notes:

Re: kafka stream processor's process method

2021-01-11 Thread Bruno Cadonna
Hi Sathya, MyProcessor does not have access to MySource, because in MySource you just build the topology that is then executed by Kafka Streams. So you cannot send anything to MySource, because MyProcessor does not know anything about MySource. If you want to stop consumption upon an