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

r1zhe5dt  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(307)

我正在构建一个应用程序,它应该检索特定使用者的流转换历史,假设我没有访问使用者的源代码。
有没有办法通过kafkaapi访问转换历史?如果没有,有没有其他可能的选择?

c0vxltue

c0vxltue1#

您不能以这种方式访问它,但是您可以构建转换,以便它们存储有关对消息进行的转换的元数据,可以作为消息值的一部分,也可以作为消息头的一部分,通过apache kafka 0.11中的kip-82/kafka-4208添加

相关问题