我有一个要求，消息以json格式来自activemq，我必须公开接收消息的端点。我正在使用kafka，但不知道是否可以使用kafkarestapi来接收json消息，并针对kafka代理中的特定主题存储它们？
hc8w905p1#
ApacheKafka核心发行版中没有RESTAPI，但是confluent提供了一个非常好的kafka开源rest代理。它支持通过restapi发布和订阅。代码和文档位于github的https://github.com/confluentinc/kafka-rest 或者您可以下载整个confluent开源平台，其中包括ApacheKafka、RESTProxy、SchemaRegistry和其他一些有用的增强功能http://www.confluent.io/download/
1条答案
按热度按时间hc8w905p1#
ApacheKafka核心发行版中没有RESTAPI，但是confluent提供了一个非常好的kafka开源rest代理。它支持通过restapi发布和订阅。代码和文档位于github的https://github.com/confluentinc/kafka-rest 或者您可以下载整个confluent开源平台，其中包括ApacheKafka、RESTProxy、SchemaRegistry和其他一些有用的增强功能http://www.confluent.io/download/