我们正在尝试使用kafka作为源来构建一个datatorrent应用程序，该应用程序将使用rest从webui消费消息。有人能提供一个好的文档或一些步骤如何设置Kafka生产使用JavaRESTAPI？谢谢
nkkqxpd91#
或者，如果您不想对kafka使用合流rest代理，可以使用web框架运行web应用程序，该框架将在客户端的http请求期间调用kafka客户端库。
w9apscun2#
看看Kafka休息。它将允许您使用json或avro格式的restapi向kafka主题生成消息。它是用java编写的，如果您没有特殊的需求，您可以开箱即用。
2条答案
按热度按时间nkkqxpd91#
或者，如果您不想对kafka使用合流rest代理，可以使用web框架运行web应用程序，该框架将在客户端的http请求期间调用kafka客户端库。
w9apscun2#
看看Kafka休息。
它将允许您使用json或avro格式的restapi向kafka主题生成消息。它是用java编写的，如果您没有特殊的需求，您可以开箱即用。