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

Kafka State Store low level API persist into ROCKDB ? if yes then is there any documentation for configuration for ROCK DB

Kafka State Store 低级别 API 持久化到 ROCKDB 中?如果是,那么是否有任何 ROCK DB 的配置文档。如果不是,那么低级别使用什么 API Stores.create().withKeys().withValues().persistent().build();

您可以通过实现 RocksDBConfigSetter 接口来提供自定义 RocksDB 配置,并将实现 class 添加到 StreamsConifg:

streamsConfig.put(StreamsConfig.ROCKSDB_CONFIG_SETTER_CLASS_CONFIG, CustomRocksDBConfig.class);

参见:http://docs.confluent.io/current/streams/developer-guide.html#non-streams-configuration-parameters