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
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