Невозможно создать тему с проверкой правильности схемы по умолчанию | Confluent Platform

Я пытаюсь создать тему, используя команду ниже

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


person aggarwalb    schedule 03.02.2021    source источник


Ответы (1)


Эта конфигурация доступна только в Confluent Server, но не в Apache Kafka.

Вы говорите, что используете Kubernetes, поэтому убедитесь, что изображение вашего модуля confluentinc/cp-server, не confluentinc/cp-enterprise-kafka

person OneCricketeer    schedule 03.02.2021
comment
В документации я вижу, что cp-server является коммерческим компонентом платформы Confluent. Есть ли способ создавать темы с включенной проверкой схемы в компоненте сообщества? Это поддерживается? - person aggarwalb; 04.02.2021
comment
Проверка на стороне темы / сервера не поддерживается за пределами Confluent Server, только проверка на стороне сообщения / клиента. Если вы хотите заблокировать определенные клиенты и темы, чтобы предотвратить злоумышленников, настройте политики и сертификаты ACL. - person OneCricketeer; 04.02.2021