Kafka-Streams - 在加入之前过滤 GlobalKTable
Kafka-Streams - Filtering GlobalKTable before Joining
能否就以下问题的方法给我一个建议。我有两个主题，一个是静态内容，第二个是数据流。任务是加入数据，这在正常情况下很容易。我会将静态内容读取为 GlobalKTable，将动态内容读取为 KStream，然后简单地加入它们。问题是查找数据存在于同一主题的多个版本中。 "versions" 由字段 "validFrom" 标识。所以流的数据需要根据他们的时间戳与相应版本的查找数据连接起来。有没有办法过滤 GlobalKTable 中的数据？
此致
马丁
您不能对 GlobalKTable 本身应用过滤操作，但您可以尝试测试 ValueJoiner 中记录的版本，并设置未通过的连接结果记录的值测试 null。加入后，您可以应用筛选器，筛选出值为 null.
的所有记录
能否就以下问题的方法给我一个建议。我有两个主题，一个是静态内容，第二个是数据流。任务是加入数据，这在正常情况下很容易。我会将静态内容读取为 GlobalKTable，将动态内容读取为 KStream，然后简单地加入它们。问题是查找数据存在于同一主题的多个版本中。 "versions" 由字段 "validFrom" 标识。所以流的数据需要根据他们的时间戳与相应版本的查找数据连接起来。有没有办法过滤 GlobalKTable 中的数据？
此致 马丁
您不能对 GlobalKTable 本身应用过滤操作，但您可以尝试测试 ValueJoiner 中记录的版本，并设置未通过的连接结果记录的值测试 null。加入后，您可以应用筛选器，筛选出值为 null.