如何使用 confluent rest api 创建 kafka 主题答案

【问题标题】：how to create kafka topic using confluent rest api如何使用 confluent rest api 创建 kafka 主题
【发布时间】：2021-07-21 18:24:08
【问题描述】：

端点：http://localhost:8082/v3/clusters/cluster-id/topics

帖子正文：{ "topic_name": "topic-X", “partitions_count”：1， “复制因子”：1， “配置”：[ { "name": "cleanup.policy", “价值”：“紧凑” }, { "name": "compression.type", “价值”：“gzip” } ] }

异常：java.lang.NullPointerException：无法调用“io.confluent.kafkarest.entities.v3.CreateTopicRequest.getTopicName()”，因为“request”为空在 io.confluent.kafkarest.resources.v3.TopicsResource.createTopic(TopicsResource.java:137)

【问题讨论】：

这能回答你的问题吗？ Is it possible to create a topic with Kafka Rest Proxy?

标签： apache-kafka confluent-platform kafka-rest

【解决方案1】：

将端口从 8082 更改为 8090 后可以创建主题端点：http://localhost:8090/v3/clusters/cluster-id/topics。

几件事。根据 confluent 文档默认监听器是 8082，不确定 8090 端口配置

听众

类型：列表默认值：http://0.0.0.0:8082 重要性：高

https://docs.confluent.io/platform/current/kafka-rest/production-deployment/rest-proxy/config.html

【讨论】：

如果 8082 端口不正确，你根本不会得到任何响应