访问 Kafka 流转换历史的选项?
Options to access Kafka stream transformation history?
我正在构建一个应用程序,它应该检索特定消费者的流转换历史记录,假设我无法访问消费者的源代码。
有什么方法可以通过 Kafka 访问转换历史记录 API?如果没有,是否有任何可能的替代方案?
您不能以那种方式访问它,但您可以构建您的转换,以便它们存储关于对消息完成的转换的元数据,作为消息值的一部分,或者它在 Apache 中的 Header, added through KIP-82/KAFKA-4208卡夫卡 0.11
我正在构建一个应用程序,它应该检索特定消费者的流转换历史记录,假设我无法访问消费者的源代码。
有什么方法可以通过 Kafka 访问转换历史记录 API?如果没有,是否有任何可能的替代方案?
您不能以那种方式访问它,但您可以构建您的转换,以便它们存储关于对消息完成的转换的元数据,作为消息值的一部分,或者它在 Apache 中的 Header, added through KIP-82/KAFKA-4208卡夫卡 0.11