在 Kafka Streams 中获取输出记录分区

Question

我有一个 KStream，它根据一些内部逻辑将输出记录分支并写入不同的主题。有什么方法可以从 KStream 内部知道输出消息的分区吗？输出主题的分区数量与输入主题不同。

Answer 1

使用高级 DSL 时，您无权访问记录元数据（该元数据保存记录来自的特定分区上的键/值对）。因此，您将无法使用 KStream 实现来实现目标。

如果需要，您可以使用低级处理器 API，这将允许访问元数据。否则，您可以添加 ConsumerInterceptor 的实现，并将分区值映射到消息，然后再发送给消费者。