Commit 86ba4d8f authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia propiedades session y heartbeat

parent 8d4aa701

src/main/java/es/redmic/commandslib/streaming/common/StreamUtils.java

+2 −1
Original line number Diff line number Diff line
@@ -34,7 +34,8 @@ public class StreamUtils { 
		config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");



		config.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 50);

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 30000);

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 300000);

		config.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 90000);



		// config.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG,

		// StreamsConfig.EXACTLY_ONCE);