Hi… for EOS i added these configurations in my kstream application… i am running my application on 2 kafka brokers … when both my brokers are going down the application goes down getting this exception
Timed out while committing offsets via consumer
and when i restart it, few messages are getting reprocessed… any idea how to fix this
streamsConfiguration.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
streamsConfiguration.put(StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG, LogAndContinueExceptionHandler.class.getName());
streamsConfiguration.put(StreamsConfig.DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG, ADTProducerExceptionHandler.class);
streamsConfiguration.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG,StreamsConfig.EXACTLY_ONCE_BETA);
streamsConfiguration.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION_CONFIG, StreamsConfig.OPTIMIZE);
streamsConfiguration.setProperty(ProducerConfig.ACKS_CONFIG, "all");
streamsConfiguration.setProperty(ProducerConfig.RETRIES_CONFIG,Integer.MAX_VALUE+"");```