подскажите пожалуйста как заставить UI debezuim автоматом создавать топики при настройке коннектора?
Использую образ
kafka image: docker.io/bitnami/kafka:3.4 с переменной KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true, а также образ
kafka-connect image: quay.io/debezium/connect:latest с переменной CONNECT_TOPIC_CREATION_ENABLE=true.
Читаю доку https://debezium.io/documentation/reference/stable/configuration/topic-auto-create-config.html и не пойму чего еще не хватает, UI debezuim все равно пишет "Kafka automatic topic creation is not enabled. See documentation for details on enabling this feature."
эта (KAFKA_CFG_AUTO_CREATE_TOPICS_ENABL) опция включается на кафке, а не в коннекторе(дебезиуме)
так вот же Использую образ kafka image: docker.io/bitnami/kafka:3.4 с переменной KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true
"докажите") что вы эту переменную передаёте в кафку. По ссылке на докер-образ это неочевидно)
Настройка на брокере раз, настройка создания топиков в самом коннекторе - два
Ну я бы приложил скрин в качестве доказательства, но тут нельзя) Сейчас проверил через kafka ui - в настройках брокера стоит auto.create.topics.enable true
оба этих условия учтены переменными докера, вроде как
может вы не к той кафке коннектитесь? попробуйте любым другим консьюмером подключиться к ней и проверить будет ли топик создан автоматически
Настройки коннектора не в докере, не путайте с коннектом
тут не совсем понял, через env докера передаю переменную которая подтягивается в конфиг kafka-connect, или вы про другое?
Есть сервак - Кафка-коннект, у него свой конфиг, а есть коннекторы - они ставятся на сервак у них свои конфиги
Обсуждают сегодня