生産者としてのTCPポートを持つSpring Kafka - java、spring、tcp、apache-kafka、kafka-producer-api

私はカフカとストリーミングを初めて知りました。

私はインストールし、両方の動物園とカフカは成功した。シンプルなトピックを作成し、そのトピックに送信されているものをコンソールでリッスンして表示するコンソールコンシューマを開始しました。 プロデューサは現在、エンドポイント呼び出しの結果として情報を送信します。

私は送信されるデバイスを持っています NMEA TCPポートにデータをフォーマットします。 どのように私はKafkaプロデューサーとしてTCPポートを公開できますか？

誰かが助けるために余分な情報を必要とするならば、躊躇しないでください。

回答：

TCPポートをリッスンし、必要な形式にデータをデコードして、それをサーバーに渡すよりも、アプリケーションを書く必要があります。 KafkaProducer それをトピックに書き込む