我有一个 Spring boot Kafka Stream 应用程序,它处理所有传入事件并将其存储在 Kafka Streams 内部提供的状态存储中,并使用交互式查询服务对其进行查询。在所有使用“RocksDB”的 Kafka Streams 中,我想用任何其他可配置的数据库(如 MariaDB 或 MongoDB)替换此 RocksDB。有办法做到吗?如果不
我如何配置 Kafka Stream 应用程序以使用 MongoDB 创建状态存储。
mongodb apache-kafka spring-cloud-stream apache-kafka-streams