Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.19.0
-
None
-
Unknown
Description
We should be able to configure the cache on the resume strategy configuration builders:
KafkaResumeStrategyConfigurationBuilder kafkaConfigurationBuilder = KafkaResumeStrategyConfigurationBuilder.newBuilder() .withBootstrapServers("kafka-address:9092") .withTopic("offset") .withProducerProperty("max.block.ms", "10000") .withMaxInitializationDuration(Duration.ofSeconds(5)) .withCache(myCacheInstance); // <--- like this