通过http向kafka发布消息

Question

我是kafka的新手，我正试图通过http从外部应用程序发布数据，但我找不到这样做的方法。

我已经在kafka中创建了一个主题，并测试它生成和使用消息，但我不知道如何通过http插入/发布消息，我试图调用以下url来检索主题，但它不检索任何数据http://servername:2181/topics/

我正在使用cloudera 5.12.1。

Answer 1

查看Confluent中的开源Kafka REST Proxy。它完全符合你的要求。

你可以得到它standalone，或作为Confluent Platform的一部分。

Answer 2

您可以使用APIs访问已创建的主题（如果已创建）。简单的方法......（见client list）

或者请参阅Connects Config以通过REST管理连接器（rest.host.name，rest.port参数）。但只有连接器......要在主题中使用或生成消息，请使用中间件。 IT更容易受到影响。