Commit 25ca3689 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade nuevos parámetros de configuración a streams

parent f5fa96a3

src/main/java/es/redmic/commandslib/commands/CommandHandler.java

+0 −1
Original line number Diff line number Diff line
@@ -44,7 +44,6 @@ public abstract class CommandHandler implements ApplicationEventPublisherAware { 
	/* Handler por defecto para descartar los mensajes que no queremos */

	@KafkaHandler(isDefault = true)

	public void defaultListen(Object event) {

		logger.info("Mensaje descartado: " + event.getClass());

	}



	// Resuelve el CompletableFuture con el evento recibido

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

+6 −0
Original line number Diff line number Diff line
@@ -31,6 +31,12 @@ public class StreamUtils { 
		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.MAX_POLL_RECORDS_CONFIG, 50);

		config.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 600000);

		config.put(StreamsConfig.REQUEST_TIMEOUT_MS_CONFIG, 605000);

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 30000);



		// config.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG,

		// StreamsConfig.EXACTLY_ONCE);

		config.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1); // commit as fast as possible