代码之家 › 专栏 › 技术社区 › gokareless

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

apache-kafka-streams kafka-consumer-api apache-kafka

gokareless · 技术社区 · 7 年前

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

有没有办法通过Kafka API访问转换历史?如果没有,有什么可能的选择吗?

1 回复 | 直到 7 年前

Robin Moffatt 7 年前

您不能以这种方式访问它,但是您可以构建您的转换,以便它们存储有关对消息所做的转换的元数据,或者作为消息值的一部分,或者 Header ,通过 KIP-82 / KAFKA-4208 阿帕奇卡夫卡0.11

推荐文章

Shubham Snehi · Golang Segmentation在消费者组迁移时获得一半分区

2 年前

Varun Sharma · 从Kaffa主题消费并添加到列表中

2 年前

Andrey P. · 添加spring-cloud-starter-bus-Kafka依赖项后,Kafka消费者没有收到消息

2 年前

Evgeniy Zhurenko · 为什么卡夫卡的消费者没有收到经纪人的记录

2 年前

Dev9321 · Kafka消费者组没有消费来自所有消费者的消息

3 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

4 年前

BnJ · 如何知道卡夫卡何时提交记录?

8 年前

addictedtohaskell · 为什么卡夫卡消费者无视我在汽车上的“最早”指令。抵消重置参数,从而不从绝对第一个事件读取我的主题?

8 年前

maverick · 消息预处理(主题-主题)-Kafka Connect API vs.Streams vs Kafka Consumer?

8 年前

Renato Garcia · 如何设置隔离。等级卡夫卡骆驼组件

8 年前