使用文档中提供的Kafka rest配置选项consumer.instance.timeout.ms时出现的问题

Question

Kafka rest代理在尝试合流文档中提供的某些参数时失败
当尝试使用文档中提供的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"}'

我正在docker上运行最新版本的融合平台5.5.1，只有zookeeper、kafka、schema registry和rest代理服务
这不是使用配置选项的正确方式吗？或者还有其他方式可以使用这些配置选项吗？

Answer 1

您链接到的文档(特别是consumer.instance.timeout.ms参数(是为Kafka REST代理服务器本身准备的。

仅支持一个子集的选项，以允许消费者通过API配置自己，这些选项在API参考中列出。