使用kafka流、KStream-GlobalKtable联接进行数据充实

Question

null: { "ID":"1", "name":"XDFER"}
null: { "ID":"1", "name":"TRAFD"}

XDFER : "john"
TRAFD : "albert"

null: { "ID":"1", "name":"john"}
null: { "ID":"1", "name":"albert"}

我开始阅读Kafka Stream应用程序，在每个教程/示例中，通过比较KStream和GlobalkTable中的键来丰富数据。在我的情况下，我需要将KStream记录的值中的一个项与GlobalKTable中的一个键进行比较。如何实现这一点的任何想法或例子。

Answer 1

具有null键或null值的流的输入记录将被忽略，并且不会触发联接。

因此，您需要重新确定流的密钥，以便可以使用name作为密钥。

stream.selectKey(v-> v.get("name"))

重新键入后，您就可以将stream与GlobalKtable连接起来。