时间戳

首页 > 解决方案 > 使用文档中提供的 Kafka 休息配置选项 consumer.instance.timeout.ms 的问题

apache-kafka - 使用文档中提供的 Kafka 休息配置选项 consumer.instance.timeout.ms 的问题

问题描述

尝试融合文档中提供的某些参数时，Kafka 休息代理失败。
当尝试使用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-proxy 服务。
这不是使用配置选项的正确方法，还是有其他方法可以使用这些配置选项？

标签： apache-kafkaconfluent-platformkafka-rest

解决方案

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

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

推荐阅读