Error in kafka streams: The producer attempted to use a producer id which is not currently assigned to its transactional id

Hello All, While using kafka streams application, we are intermittently getting following exception and stream is closed. We need to restart the application to get it working again and start processing. This exception is observed in some of the labs which are being idle for some time but it is not

Mirrormaker 2 failed to get offset

Hi, I am trying to set-up kafka mirrormaker 2 for kafka 2.4. It worked first time. But I am getting following error when I try to restart it. I have set request.timeout.ms to 6 for both clusters and producer. How do increase 3ms limit or change any other config value to fix it. [20

Re: Error in kafka streams: The producer attempted to use a producer id which is not currently assigned to its transactional id

This version are you using? Couple of broker and client side exactly-once related bugs got fix in the latest release 2.5.0. -Matthias On 4/23/20 11:59 PM, Pushkar Deole wrote: > Hello All, > > While using kafka streams application, we are intermittently getting > following exception and stream

Re: Unknown topic at org.apache.kafka.streams.TopologyTestDriver.pipeRecord

Can you inspect the output of `Topology#describe()#toString()`? It might also be a bug. What version are you using? Can you reproduce the issue reliably (if yes, can you share you code so we can have a more detailed look)? -Matthias On 4/21/20 7:02 AM, Murilo Tavares wrote: > If topic is "users