春のカフカ、TCPポートをプロデューサーとして

Question

私はカフカとストリーミングを使い慣れていますので、私に同行してください。

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

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

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

Answer 1

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