apache-kafka - 我可以通过现有的 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 目录中的其余内容(即与代理相关的内容)拖到我的系统中?因为它们不是必需的。是否有一些预先存在的解决方案?
谢谢你。
解决方案
如果必须使用 JVM 解决方案,则必须构建自己的工具,并依赖于org.apache.kafka:kafka-clients
如果可以使用其他解决方案, kafkacat
就是它自己的独立、可移植脚本。
推荐阅读
- swift - 使用 popOver 打开第二个视图时不调用 viewWillDisapper
- python - 如何在不重复计算的情况下计算 python 中数据框的所有唯一值?
- android - 当我尝试加载图像资产时不断收到此错误“发生异常。FlutterError(无法加载资产:assests/1.png)”
- api - 如何从 API Graph 获取在线会议 ID?
- javascript - 在元素外部单击时未调用 on("blur")
- javascript - 将 JS 附加到 HTML
- swift - "localizedStringWithFormat" 更改语言而不重新启动应用程序
- rxjs - rxjs:在 switchMap'ped 后访问原始 observable 的结果
- python - 有没有办法在熊猫中进行分组,然后在另一列具有指定值的情况下计算唯一性?
- laravel - laravel:laravel Vue ui 中的默认验证在哪里?