使用KAFKA REST API消费JSON消息



我有一个要求,消息来自ACTIVEMQ的json格式,我必须暴露端点,我可以接收消息。我正在使用KAFKA,但不知道是否可以使用KAFKA REST API来接收json消息并将其存储在KAFKA代理中的特定主题?

核心Apache Kafka发行版中没有REST API,但是Confluent提供了一个非常好的Kafka开源REST代理。它支持通过REST api发布和订阅。代码和文档在github上https://github.com/confluentinc/kafka-rest,或者你可以下载整个Confluent开源平台,包括Apache Kafka, REST代理,Schema Registry和其他一些有用的增强,http://www.confluent.io/download/

最新更新