代码之家 › 专栏 › 技术社区 › C.med

使用kafka producer发送日志文件

apache-kafka-connect kafka-producer-api apache-kafka python

C.med · 技术社区 · 6 年前

我想创建一个python脚本,将文件从虚拟机发送到kafka代理。简单来说:

局限性

我想我需要创建一个连接器?我们能重复使用类似的东西吗 connect-file-sink.properties连接文件接收器 并指定文件存储在外部计算机中的文件夹+IP: VM1

还有别的工具可以做吗?

1 回复 | 直到 6 年前

Robin Moffatt 6 年前

有很多现有的工具可以做到这一点,例如。 Filebeat 支持 output to Kafka , Fluentd 等。

这些都是简单的设置简单的配置文件。最棘手的一点可能是你的人际网络——只要确保 configured Kafka's listeners correctly .

推荐文章

Google User · Django管理员在`list_display中未显示`creation_date`字段`

11 月前

user29747013 · 如何创建一个新的数据框架,其中包含原始数据框架中列的聚合列?

11 月前

ÎÎÎ½Î· ÎÎ®Î¹Î½Î¿Ï · Python lxml.html语法错误:使用lxml find时XPATH的谓词无效

11 月前

user29715306 · from_users=和chats=电视节目中的差异

11 月前

Redshoe · 当执行numpy.genfromtxt()时,python是否会读取文件的所有行?

11 月前

RASEL MAHMUD · 为什么以及如何在is_even()函数内的IF条件中递归X变量在满足0后递增?[副本]

11 月前

prayner · 更新嵌套字典包含列表中的项

11 月前

Bringo Jr · 我可以在O(n)中解决这个问题吗?

11 月前

Dave · 如何在for循环中修改列表值

11 月前

Shukurullox Komiljonov · 从记录中获得相互和解。使用SQL

11 月前