Hello! I'd like to use this thread to discuss KIP-605, which expands some of the properties that the Connect distributed worker uses when creating internal topics:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-605%3A+Expand+Connect+Worker+Internal+Topic+Settings Best regards, Randall