通过 flume 输入 kafka 和直接用 kafka API 有什么优劣呢?

向 kafka 写入数据,可以有以下两种方式:

  1. 不断写入文件,通过 flume 配置,用 flume 写入 kafka;
  2. 使用 kafka api 写入;

请问这两者各有什么优劣呢?

阅读 4.3k
2 个回答

其它区别我说不上来,但个人理解flume是用于采集日志文件的,日志文件本身没有调用kafka api的能力,所以需要用到flumelogstashfilebeat等工具来作采集,如果是应用程序向kafka输出信息的话,用kafka api应该没有问题的吧

没怎么用过flume,但是很明显的,使用kafka api更加灵活,数据结构,根据规则分配到不同partition,顺序性等,都能实现。
flume应该是在kafka api上包装了一层,更加的方便实用。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进