Re: Using processor API via DSL

Hi Bruno, thanks a lot for checking the code, regarding the SpecificAvroSerde I've found that using final Serde valueSpecificAvroSerde = new SpecificAvroSerde<>(); final Map serdeConfig = Collections.singletonMap("schema.registry.url", "http://localhost:8081";); valueSpecificAvroSerde.configure(se

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Thank you all! -Matthias On 4/19/19 3:58 PM, Lei Chen wrote: > Congratulations Matthias! Well deserved! > > -Lei > > On Fri, Apr 19, 2019 at 2:55 PM James Cheng > wrote: > > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, a

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congratulations Matthias! Well deserved! -Lei On Fri, Apr 19, 2019 at 2:55 PM James Cheng wrote: > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > > > Hello Everyone, > > > > I'm glad to announce that Matthias J. Sax is now a member of

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congratulations, Matthias! best, Colin On Fri, Apr 19, 2019, at 14:55, James Cheng wrote: > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > > > Hello Everyone, > > > > I'm glad to announce that Matthias J. Sax is now a member of Kafk

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats!! -James Sent from my iPhone > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > Hello Everyone, > > I'm glad to announce that Matthias J. Sax is now a member of Kafka PMC. > > Matthias has been a committer since Jan. 2018, and since then he continued > to be active in the commu

Re: NotEnoughReplicasException on __transaction_state after bring down one of kakfa broker

The docs indicate that exception is thrown when the "number of insync replicas for the partition is lower than min.insync.replicas". https://kafka.apache.org/20/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasException.html When you took your broker offline, your messages couldn't be repl

Re: Using processor API via DSL

Hi Alessandro, I had a look at your code. Regarding your question whether you use the SpecificAvroSerde correctly, take a look at the following documentation: https://docs.confluent.io/current/streams/developer-guide/datatypes.html I haven't had the time yet to take a closer look at your problem

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Thanks, Everyone. -Harsha On Fri, Apr 19, 2019, at 2:39 AM, Satish Duggana wrote: > Congrats Harsha! > > On Fri, Apr 19, 2019 at 2:58 PM Mickael Maison > wrote: > > > Congratulations Harsha! > > > > > > On Fri, Apr 19, 2019 at 5:49 AM Manikumar > > wrote: > > > > > > Congrats Harsha!. > > > >

Re: Kafka point in time recovery?

Hello Kumar, if I got it correctly, you can try with the method offsetsForTimes from the KafkaConsumer Api. Maybe you can reset the offset to a particular timestamp and consume up to a certain offset or timestamp. https://kafka.apache.org/22/javadoc/?org/apache/kafka/clients/consumer/KafkaConsume

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congrats Harsha! On Fri, Apr 19, 2019 at 2:58 PM Mickael Maison wrote: > Congratulations Harsha! > > > On Fri, Apr 19, 2019 at 5:49 AM Manikumar > wrote: > > > > Congrats Harsha!. > > > > On Fri, Apr 19, 2019 at 7:43 AM Dong Lin wrote: > > > > > Congratulations Sriharsh! > > > > > > On Thu, Ap

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congratulations Harsha! On Fri, Apr 19, 2019 at 5:49 AM Manikumar wrote: > > Congrats Harsha!. > > On Fri, Apr 19, 2019 at 7:43 AM Dong Lin wrote: > > > Congratulations Sriharsh! > > > > On Thu, Apr 18, 2019 at 11:46 AM Jun Rao wrote: > > > > > Hi, Everyone, > > > > > > Sriharsh Chintalapan ha

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats Matthias! On Fri, Apr 19, 2019 at 6:07 AM Vahid Hashemian wrote: > > Congratulations Matthias! > > --Vahid > > On Thu, Apr 18, 2019 at 9:39 PM Manikumar wrote: > > > Congrats Matthias!. well deserved. > > > > On Fri, Apr 19, 2019 at 7:44 AM Dong Lin wrote: > > > > > Congratulations Mat