Spring 使用 TCP 端口作为生产者的 Kafka

Question

我是 Kafka 和 Streaming 的新手，请多多包涵。

我已经成功安装并启动了 zookeeper 和 Kafka。创建了一个简单的主题并启动了控制台消费者，它在控制台中监听和显示发送到该主题的内容。 生产者当前作为端点调用的结果发送信息。

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

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

Answer 1

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