Kafka 生产者从 PORT 向主题生产数据

Question

我是卡夫卡的新手。

我有一台 Linux 机器，其中端口号 2552 从外部服务器获取数据流。

我想使用 Kafka 生产者来监听该端口并将数据流获取到某个主题。

Answer 1

这是一个完整的黑客，但适用于沙箱示例：

nc -l 2552 | ./bin/kafka-console-producer --broker-list localhost:9092 --topic test_topic

它使用 netcat 侦听 TCP 端口，并将收到的任何内容通过管道传输到 Kafka 主题。

快速谷歌也发现了这个https://github.com/dhanuka84/kafka-connect-tcp，它看起来使用 Kafka Connect API 做类似的事情，但更强大。