-
2 votesanswersviews
Kafka流以特定键作为输入连接
我在架构注册表中有3个不同的主题和3个Avro文件，我想流式传输这些主题并将它们连接在一起并将它们写入一个主题 . 问题是我要加入的密钥与我将数据写入每个主题的密钥不同 . 假设我们有这3个Avro文件：Alarm ： { "type" : "record", "name" : "Alarm", "... -
0 votesanswersviews
KStream到KTable左连接返回Null
我目前正在尝试使用KStream到KTable连接来执行Kafka主题的丰富 . 对于我的概念证明，我目前有一个Kafka Stream，其中包含大约600,000条记录，这些记录都具有相同的密钥，并且KTable是从一个主题创建的，其中包含一个密钥，值对的1个记录，其中KTable主题中的密钥与600,000的密钥相匹配创建KStream主题中的记录 . 当我使用左连接（通过下面的代码）时，所有...