Блог

Главная - Вопросы по программированию - Проблемы с использованием опции конфигурации Kafka rest consumer.instance.timeout.ms предусмотрено в документации

Проблемы с использованием опции конфигурации Kafka rest consumer.instance.timeout.ms предусмотрено в документации

#apache-kafka #confluent-platform #kafka-rest

#apache-kafka #confluent-платформа #kafka-rest

Вопрос:

Сбой прокси Kafka rest при попытке использовать некоторые параметры, указанные в документах confluent.
При попытке использовать параметры, подобные consumer.instance.timeout.ms , которые указаны в документации[https://docs.confluent.io/current/kafka-rest/config.html ] сбой.

Запрос

 curl -X POST http://172.16.x.x:8082/consumers/onerp -H "Content-Type: application/vnd.kafka.v2 json" -d '{"name": "ins-b", "format": "binary", "auto.offset.reset": "earliest", "auto.commit.enable": "false", "consumer.instance.timeout.ms": 180000}'

Ответ

 {"error_code":422,"message":"Unrecognized field: consumer.instance.timeout.ms"}

Однако запрос с минимальными параметрами конфигурации выполняется успешно:

 curl -X POST http://172.16.x.x:8082/consumers/onerp -H "Content-Type: application/vnd.kafka.v2 json" -d '{"name": "ins-b", "format": "binary", "auto.offset.reset": "earliest", "auto.commit.enable": "false"}'

Я запускаю последнюю версию confluent platform 5.5.1 в docker только с zookeeper, kafka, schema-registry и службами rest-proxy.
Это неправильный способ использования параметров конфигурации или есть какой-либо другой способ использовать эти параметры конфигурации?

Ответ №1:

Документация, на которую вы ссылались (и consumer.instance.timeout.ms параметр, в частности), предназначена для самого прокси-сервера Kafka REST.

Поддерживается только подмножество опций, позволяющих пользователю настраивать себя через API, и они перечислены в ссылке на API.