Commit c148d747 authored by Pedro Eduardo Trujillo's avatar Pedro Eduardo Trujillo
Browse files

Deja commit interval por defecto (30ms)

Es posible que muchas caídas del servicio se deban a este ajuste,
que fuerza demasiado al proceso de stream lanzando una petición de
commit a cada milisegundo.
parent 0dacab14
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -32,7 +32,7 @@ public class StreamsApplicationUtils {
		config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
		// config.put(StreamsConfig.STATE_DIR_CONFIG, stateDir);
		config.put(AUTO_OFFSET_RESET, autoOffsetReset);
		config.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1); // commit as fast as possible
		//config.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1); // commit as fast as possible

		config.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 60000);
		config.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 15000);