Refactoring

src/main/resources/application-prod.properties

@@ -92,6 +92,24 @@ kafka.bootstrap.servers=${KAFKA_BOOTSTRAP_SERVERS:kafka-service.kafka.svc.cluste
 mp.messaging.connector.smallrye-kafka.health-enabled=true
 mp.messaging.connector.smallrye-kafka.health-readiness-enabled=true
 
+# Tuning consumers: évite "Commit cannot be completed since the group has already rebalanced"
+# et "This is not the correct coordinator" (dépassement max.poll.interval = consumer exclu).
+# - max.poll.interval.ms: délai max entre deux poll() (défaut 5 min) -> 10 min en prod
+# - max.poll.records: moins de messages par poll() = traitements plus courts, moins de risque de timeout
+# - session.timeout.ms: délai avant de considérer le consumer mort (heartbeat)
+mp.messaging.incoming.kafka-notifications.max.poll.interval.ms=600000
+mp.messaging.incoming.kafka-notifications.max.poll.records=100
+mp.messaging.incoming.kafka-notifications.session.timeout.ms=45000
+mp.messaging.incoming.kafka-chat.max.poll.interval.ms=600000
+mp.messaging.incoming.kafka-chat.max.poll.records=100
+mp.messaging.incoming.kafka-chat.session.timeout.ms=45000
+mp.messaging.incoming.kafka-reactions.max.poll.interval.ms=600000
+mp.messaging.incoming.kafka-reactions.max.poll.records=100
+mp.messaging.incoming.kafka-reactions.session.timeout.ms=45000
+mp.messaging.incoming.kafka-presence.max.poll.interval.ms=600000
+mp.messaging.incoming.kafka-presence.max.poll.records=100
+mp.messaging.incoming.kafka-presence.session.timeout.ms=45000
+
 # ====================================================================
 # WebSocket / SSL / Performance / Localisation
 # ====================================================================