如何将 Kafka 流的简单整数密钥转换为复杂的 Avro 类型密钥

Question

我有一个流式应用程序拓扑结构，它使用一个带有整数键和 AVRO 主体的简单主题。我想操纵流并使用复杂的 AVRO 密钥写入主题。但是我找不到相当于 mapValues() 的“键”。换句话说，我似乎被原来的 Integer 键卡住了。我可以转换这个吗？

Answer 1

“等价”就是

map()

。您将以未修改的形式返回 KeyValuePair 类型中的值。

Answer 2

我刚找到我需要的东西：selectKey((k, v) -> newKey)

    kstream.selectKey((k, v) -> AvroObjBuiltFromAvsc.newBuilder().setValue("abc").build())
.to("topic_with_avro_key");