Hi all, I’m trying to make use of the somewhat new functionality of Connect to create new topics on the fly as described in KIP-158<https://cwiki.apache.org/confluence/display/KAFKA/KIP-158%3A+Kafka+Connect+should+allow+source+connectors+to+set+topic-specific+settings+for+new+topics>. My test is really simple, and consists of setting the two required configurations below:
topic.creation.default.replication.factor=3 topic.creation.default.partitions=1 The issue is that it only works when I set them via Connect API (PUT …/config) after the connect cluster is up. Setting the same configs at startup via “worker.properties” file does not work. Is this the intended behavior or is it a bug? Is there a known workaround for me to set those properties at startup? Cheers, Fabio
