Re: MirrorMaker 2 with SSL

2021-04-15 Thread Men Lim
well the 405 is due to a syntax error in the connector.json. after fixing that, passing the -k switch, it started. but when looking at the connect.log, mm2 is only talking in plaintext rather than SSL. After a while it timed out because the port 9094 is ssl while mm2 is trying to use plaintext.

Re: Kafka Stream: State replication seems unpredictable.

2021-04-15 Thread mangat rai
Guozhang, Yes, you are correct. We have our own group processor. I have more information now. 1. I added ThreadId in the data when the app persists into the changelog topic. 2. Thread-2 which was working with partition-0 had a timeout issue. 4. Thread-4 picked up this partition-0 as I can see