Re: Timestamps unique?

2022-01-13 Thread Svante Karlsson
No guarantee, /svante Den tors 13 jan. 2022 kl 20:21 skrev Chad Preisler : > > Hello, > > For ConsumerRecord.timestamp() is the timestamp guaranteed to be > unique within the topic's partition, or can there be records inside the > topics partition that have the same timestamp? > > Thanks. > Chad

Timestamps unique?

2022-01-13 Thread Chad Preisler
Hello, For ConsumerRecord.timestamp() is the timestamp guaranteed to be unique within the topic's partition, or can there be records inside the topics partition that have the same timestamp? Thanks. Chad

Re: Kafka streams usecase

2022-01-13 Thread Chad Preisler
Yes Kafka streams can be used to do this. There are probably several ways to implement this. We did something like this in Java using a groupByKey() and reduce() functions. The three topics we wanted to combine into one topic had different schemas and different java class types. So to combine them

RE: Re: MirrorMaker 2 Reload Configuration

2022-01-13 Thread Praveen Sinha
Hi Peter, I am running into a similar issue, did you create a JIRA ticket for this? Or is there any workaround you have found for the same? Thanks and regards, Praveen On 2020/11/13 14:45:23 Péter Sinóros-Szabó wrote: > Hi, > > I tried as well to stop all instances of MM2, but it didn't help for