只是想知道在用kafka streams builder编写持久层时,我可能会遇到什么样的问题,或者使用kafka connect jdbc(sink)之类的建议?
tzdcorbm1#
是的,使用kafka connect从主题到数据存储的流正是它的用途:)如果您想在将数据登录到数据库之前处理/丰富数据,可以使用kstream(或ksql),并流式传输到第二个主题,然后将其连接起来。
1条答案
按热度按时间tzdcorbm1#
是的,使用kafka connect从主题到数据存储的流正是它的用途:)
如果您想在将数据登录到数据库之前处理/丰富数据,可以使用kstream(或ksql),并流式传输到第二个主题,然后将其连接起来。