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 # ====================================================================