From a515963a4a813ffefbd3a33ad66aafe256f51467 Mon Sep 17 00:00:00 2001 From: dahoud Date: Wed, 4 Feb 2026 12:46:56 +0000 Subject: [PATCH] Refactoring --- src/main/resources/application-prod.properties | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/main/resources/application-prod.properties b/src/main/resources/application-prod.properties index 04bcc1a..ca6b4af 100644 --- a/src/main/resources/application-prod.properties +++ b/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 # ====================================================================