Druid 消费一个 kafka topic 发送到不同数据源

文章目录 背景 解决办法 一. 过滤标识在消息体中 二. 过滤标识在 header 中 源码修改逻辑 背景 数据采集时，为了避免在 kafka 中创建大量的 Topic ，采集时会将小的数据源写入一个共享 Topic 中，以某个字段作为标识。这里有两种方式： 直接将标识写入消息体中 将标识写入 record header 中 （kafka 0.11版本后支持） Druid 使用 druid-kaf

>>阅读原文<<