Spring Kafka with TCP Port 作为生产者



我是Kafka和流媒体的新手,所以请耐心等待。

我已经成功安装并启动了动物园管理员和卡夫卡。创建了一个简单的主题并启动了控制台使用者,该使用者在控制台中侦听并显示发送到该主题的内容。 创建者当前通过终结点调用发送信息。

我有一个设备,它将NMEA格式数据发送到TCP端口。 如何将 TCP 端口公开为 Kafka 生产者?

如果有人需要任何额外的信息来提供帮助,请随时询问。

您需要编写一个应用程序来侦听 TCP 端口,将数据解码为您想要的格式,然后将其交给KafkaProducer以将其写入主题。