Я пытаюсь создать тему, используя команду ниже
kafka-topics --create --bootstrap-server confluent-platform-cp-kafka:9092 --replication-factor 1 --partitions 1 --topic push.rdes.portfolios --config confluent.value.schema.validation=true
Однако я получаю следующую ошибку:
Error while executing topic command : Unknown topic config name: confluent.value.schema.validation
[2021-02-02 06:47:24,918] ERROR org.apache.kafka.common.errors.InvalidConfigurationException: Unknown topic config name: confluent.value.schema.validation
(kafka.admin.TopicCommand$)
Выполнение команды без --config confluent.value.schema.validation = true работает нормально. Вся установка выполняется в кубернетах с использованием конфлюентной диаграммы управления.
Я пробовал то же самое при локальной настройке и сталкиваюсь с той же проблемой, когда мы запускаем компоненты (zookeeper, kafka, schema registry, ksql server, kafka connect) по отдельности.
Однако команда работает, когда мы запускаем установку cp с помощью команды confluent local start.
Версия Confluent-platform: 5.5.0 и 5.5.1