Not sure if answer is relevant anymore or is feasible in your environment, but anyway: * Try deleting the topics that sc4k has created using kafka-topics.sh command * try changing the topics that sc4k is using (in the connector-distributed.proprties) ... View more

OMG! I spent at least a day (off and on) trying to figure this out. UGH. Thank you so much!!!!!! ... View more