如何解决我们可以使用其他数据库例如MariaDB或MongoDB代替Kaska Streams来存储状态,而不使用Rocks DB,是否可以配置它?
我有一个Spring boot Kafka Stream应用程序,该应用程序处理所有传入事件并将其存储在Kafka Streams内部提供的状态存储中,并使用交互式查询服务对其进行查询。在所有使用“ RocksDB”的所有Kafka流中,我想将此RocksDB替换为任何其他可配置的数据库,例如MariaDB或MongoDB。有办法吗?如果没有
如何配置Kafka Stream应用程序以使用MongoDB创建状态存储。
解决方法
StateStore / KeyValueStore是Kafka Streams中的开放接口,可以与TopologyBuilder.addStateStore
一起使用
是的,您可以使用自己选择的数据库将值具体化到自己的商店实现中,但是如果存在任何数据库连接问题,特别是对于远程数据库,它将影响处理语义。
相反,使用主题更多的事务日志,然后再使用Kafka Connect进行跟踪是适用于外部系统的正确方法
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。