apache-kafka - 如何从 Druid 访问 Kafka 事件密钥

Question

我已经设法将我的 Druid 实例连接到 Kafka，并且可以在定义 Spec 时查看事件数据。我想访问 Kafka 事件的密钥，因为它包含一些我想合并到汇总中的字段。

可能吗？

标签： apache-kafkadruid

Answer 1

快速回答：目前没有。没有可以访问密钥的 kafka 感知格式。

更长的答案：可以创建自定义 InputFormat 来支持此功能。

我将尝试创建这样一个 InputFormat 来学习 Druid 的内部并满足我的要求。

如果有什么有用的东西我会尝试贡献它。