使用Kafka rest配置选项消费者时出现的问题。例子超时。文件中提供了ms

Question

Kafka rest代理在尝试汇合文档中提供的一些参数时失败。
当尝试使用留档[https://docs.confluent.io/current/kafka-rest/config.html]中提供的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", "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，只有zoowatch、kafka、模式注册表和rest代理服务。
这不是使用配置选项的正确方式吗？或者还有其他方式来使用这些配置选项吗？

Answer 1

您链接到的文档（特别是consumer.instance.timeout.ms参数）是针对Kafka REST代理服务器本身的。

仅支持允许使用者通过API配置自身的选项子集，这些选项在API参考中列出。