我可以用与普通数据库类似的方式写入KTable吗?

Question

当使用Kafka Streams时，我知道可以通过在流上操作并以某种方式转换/聚合其中的数据来创建KTables。但我想知道是否有可能以更传统的方式使用它，比如在关系数据库中。

在关系数据库中，你可以有一个存储库，允许保存到表中:

class MyRepository {
private final JdbcTemplate jdbcTemplate;
void save(int number) {
jdbcTemplate.update("insert into my_table(number) values(?)", number);
}
}

然后你可以在代码的任何地方调用这个方法行会保存在数据库中。是否有可能对KTable做类似的事情，或者转换流是将数据放入KTable的唯一方法?

Answer 1

No。KTables不通过TCP协议(如JDBC)公开。

KTables是KV存储，不是关系存储。它们只支持范围查询或键查找。然后从处理器API将数据放入一个StateStore。