我们正在尝试使用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编写的,如果您没有特殊的需求,您可以开箱即用。