首页 > 解决方案 > 我可以通过现有的 CLI 获得一个简单的独立 Kafka Producer,而无需拖入整个 Kafka 代理库吗

问题描述

我正在尝试实现每天发送一次 Kafka 消息的 cronjob。Kafka 代理正在远程实例上运行。

我目前正在通过安装整个 Kafka 包来完成此操作,然后让 cronjob 调用如下所示的脚本:

less msg.txt | <kafka_path>/bin/kafka-console-producer.sh --broker-list <AWS_INSTANCE_IP> --topic <topic> --producer.config <property.file>

是否可以隔离 Jar(s) kafka-console-producer.sh 要求,这样我就可以做到这一点,而无需将 kafka 目录中的其余内容(即与代理相关的内容)拖到我的系统中?因为它们不是必需的。是否有一些预先存在的解决方案?

谢谢你。

标签: apache-kafka

解决方案


如果必须使用 JVM 解决方案,则必须构建自己的工具,并依赖于org.apache.kafka:kafka-clients

如果可以使用其他解决方案, kafkacat就是它自己的独立、可移植脚本。


推荐阅读