Kafka State Store 低级 API 持久化到 ROCKDB 中?如果是,那么是否有任何有关 ROCK DB



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

相关内容

最新更新