TSL and SASL for kafka and zookeeper

2021-06-11 Thread Calvin Chen
Hi all I have a question about enabling kafka and zookeeper on TSL and SASL together, that it will use TSL to do encryption and SASL to do auth, below are my config files(removed non-related info) zookeeper.conf: secureClientPort=2182 serverCnxnFactory=org.apache.zookeeper.server.NettyServerCnx

Re: LeftJoin after Map operation

2021-06-11 Thread Richard Rossel
Thanks Matthias for your help, I was able to find the issue, it was actually my Serdes definition. It is very hard to find those type problems, the execution trace log are not very helpful, and documentation regarding custom serdes are not that great. Thanks for the tip regarding the need of mate