rhauch commented on pull request #8654: URL: https://github.com/apache/kafka/pull/8654#issuecomment-628682601
BTW, I've improved the error message when Connect's `TopicAdmin` fails to create a topic because of an unknown topic setting: > Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:297) org.apache.kafka.connect.errors.ConnectException: Unable to create topic(s) 'mm2-offsets.backup.internal': Unknown topic config name: topic.replication.factor Here's what this looks like in the log message just before the herder exits: ``` [2020-05-14 09:36:22,348] ERROR [Worker clientId=connect-2, groupId=backup-mm2] Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:297) org.apache.kafka.connect.errors.ConnectException: Unable to create topic(s) 'mm2-offsets.backup.internal': Unknown topic config name: topic.replication.factor at org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:305) at org.apache.kafka.connect.storage.KafkaOffsetBackingStore$1.run(KafkaOffsetBackingStore.java:105) at org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:128) at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:115) at org.apache.kafka.connect.runtime.Worker.start(Worker.java:186) at org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:123) at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:284) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.common.errors.InvalidConfigurationException: Unknown topic config name: topic.replication.factor ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org