访问 Kafka 流转换历史的选项?

Options to access Kafka stream transformation history?

我正在构建一个应用程序,它应该检索特定消费者的流转换历史记录,假设我无法访问消费者的源代码。

有什么方法可以通过 Kafka 访问转换历史记录 API?如果没有,是否有任何可能的替代方案?

您不能以那种方式访问​​它,但您可以构建您的转换,以便它们存储关于对消息完成的转换的元数据,作为消息值的一部分,或者它在 Apache 中的 Header, added through KIP-82/KAFKA-4208卡夫卡 0.11