Commit 795c1a67 authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia estrategia de consumidor en los streams 

En lugar de usar earliest, se usa latest, para en caso de perder el
offset, no reprocesar información.
parent c7ea5749

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

+3 −3
Original line number Diff line number Diff line
@@ -51,7 +51,7 @@ public class StreamUtils { 
		config.put(StreamsConfig.APPLICATION_ID_CONFIG, appId);

		config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

		config.put(StreamsConfig.STATE_DIR_CONFIG, stateDir);

		config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

		config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");



		config.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 50);

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 300000);