kstream在非键值上与globalktable连接

hwamh0ep 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(302)

我正在尝试用globalktable连接kstream，连接不完全在键上。

GlobalKTable<String, Employee> employeesDetails = builder.globalTable("EMPLOYEE_TOPIC",..);
KStream<String,String> empIdOverLoginUserId = builder.stream("LOG_TOPIC", ….);

我想加入empidoverloginuserid和employeesdeails，empidoverloginuserid的值超过employeesdeails的键。
有什么线索吗？

apache-kafka apache-kafka-streams

来源：https://stackoverflow.com/questions/61506676/kstream-join-with-globalktable-over-non-key-values

1条答案

按热度按时间

t40tm48m1#

kstream globalktable join的第二个参数是 KeyValueMapper 要将kstream记录（键值）Map到要联接的globalktable的键，可以使用此选项在与globalktable联接时使用empidoverloginuserid的值作为键：

empIdOverLoginUserId.join(
                employeesDetails, 
                (userKey, userValue) -> userValue, 
                (userValue, employeesDetailValue) -> employeesDetailValue)

赞(0）回复(0）举报 2021-06-06

我来回答

kstream在非键值上与globalktable连接

1条答案

相关问题

热门标签

最新问答