如何使用空键连接 KStream 和 GlobalKTable，并在 json 负载中连接值？
How to join KStream and GlobalKTable with null keys and join values in json payload?
我有一个带有 null 键和值 json 的 KStream，如下所示：
{"booking_id":12,....}
还有一个 GlobalKTable，它的 JSON 负载中也有 null 密钥和预订 ID。
我想使用 booking_id 字段作为键来执行连接。
我知道 KeyValueMapper 用于 KStream 但由于这两个键都是 null 我如何执行连接操作？
如果您想使用 GlobalKTable，它必须正确设置键以用于连接。
如果您的原始主题确实有一个 null 键，您需要从 JSON 中提取该键并将结果写回第二个主题。之后，您可以将第二个主题读回作为 GlobalKTable 以用于连接。
我有一个带有 null 键和值 json 的 KStream，如下所示：
{"booking_id":12,....}
还有一个 GlobalKTable，它的 JSON 负载中也有 null 密钥和预订 ID。
我想使用 booking_id 字段作为键来执行连接。
我知道 KeyValueMapper 用于 KStream 但由于这两个键都是 null 我如何执行连接操作？
如果您想使用 GlobalKTable，它必须正确设置键以用于连接。
如果您的原始主题确实有一个 null 键，您需要从 JSON 中提取该键并将结果写回第二个主题。之后，您可以将第二个主题读回作为 GlobalKTable 以用于连接。