将 kafka-streams table 存储在数据存储中

Question

我创建了一个 KTable<Integer, CustomObject>，现在我想将此数据从 KTable 存储到 mysql 数据库。

是否可以将KTable保存到db中？我检查了 Materialized class，但我没有看到合适的方法。

final KTable<Integer, Result> result =
    users_table.join(photos_table, (a, b) ->  Result.from(a, b));

或者只有 Consumer Api 才有可能？当我阅读 "my-results" 个主题时？

Answer 1

Materialized是给configure/setKafka Streams使用的store -- 如果你没有很好的理由去改变它，建议使用默认设置。

如果你想将数据放入外部数据库，你应该将 KTable 写入主题 KTable#toStream#to("topic") 并使用 Kafka Connect 将主题中的数据加载到数据库中。