关于kafka日志导入

Question

@FrankHui 你好，想跟你请教个问题：
就是我现在不是很清楚日志的数据怎么写入到kafka，是不是需要kafka需要提供一个http的服务，然后让日志产生的时候调用http服务把数据写入kafka，还是java程序检测日子的变化然后获取日志文件内容，写入到kafka，网上都没有找到相关的内容。打扰您了。谢谢！

Answer 1

你自己仿官网上的例子写一个producer去读日志，然后将日志写入broker

Answer 2

哦，那就是用java写的producer直接读取日志文件吗，是这样吗，我是想producer如果能直接提供REST接口，这样数据产生的地方就可以直接调用这个接口，把数据写入到broker了。

非常感谢您能答复。

Answer 3

你的程序就是一个producer   直接将日志发送到broker上