KAFKA REST APIを使用してJSONメッセージを消費する

Question

メッセージがACTIVEMQからjson形式で送られ、メッセージを受信できるエンドポイントが公開されている必要があります。私はKAFKAを使用していますが、KAFKA REST APIを使用してjsonメッセージを受信し、Kafkaブローカーの特定のトピックに対してそれらを保存できるかどうかはわかりません。

Answer 1

コアApache KafkaディストリビューションにはREST APIはありませんが、Confluentから入手できるKafka用のオープンソースREST Proxyは非常に優れています。 REST APIを使用してパブリッシュとサブスクライブの両方を可能にします。コードとドキュメントはgithubのhttps://github.com/confluentinc/kafka-restにあるか、Apache Kafka、REST Proxy、Schema Registry、その他いくつかの便利な拡張機能を含むConfluentオープンソースプラットフォーム全体をhttp://www.confluent.io/download/

にダウンロードできます