Kafka State Store 低级 API 持久化到 ROCKDB 中? 如果是,那么是否有任何关于 ROCK DB 配置的文档。如果没有,那么低级 API 使用什么Stores.create((.withKeys((.withValues((.persistent((.build((;
您可以使用通过
实现RocksDBConfigSetter
接口来提供自定义 RocksDB 配置,并将您的实现类添加到StreamsConifg
:
streamsConfig.put(StreamsConfig.ROCKSDB_CONFIG_SETTER_CLASS_CONFIG, CustomRocksDBConfig.class);
请参阅:http://docs.confluent.io/current/streams/developer-guide.html#non-streams-configuration-parameters