flume+kafka实现根据消息的标识分配到不一样的分区

需求html 在使用flume 收集 log的时候根据 不一样的 消息表示多是uid。或者是日期。等关键字段 。 将消息发送到 kafka不一样的分区 这里就再也不贴详细代码 主要讲一下本身的思路 。java 思路一： 自定义在flume拦截器中 使用 kafka producer 。直接将关键信息 获取以后。根据逻辑。发送到不一样的分区 。 主要实现如图： git 配置文件修改： flume-c

>>阅读原文<<