Pourquoi je ne peux pas augmenter la session.délai d'attente.ms?

Je veux augmenter session.timeout.ms pour permettre plus de temps pour traiter les messages reçus entre poll() appels. Cependant quand je change de session.timeout.ms à une valeur supérieure à 30000, il ne parvient pas à créer de l'objet de Consommation et de lancers d'erreur ci-dessous.

Pourrait-on dire pourquoi je ne peux pas augmenter session.timeout.ms valeur ou si je suis en manque de quelque chose?

0    [main] INFO  org.apache.kafka.clients.consumer.ConsumerConfig  - ConsumerConfig values: 

request.timeout.ms = 40000
check.crcs = true
retry.backoff.ms = 100
ssl.truststore.password = null
ssl.keymanager.algorithm = SunX509
receive.buffer.bytes = 262144
ssl.cipher.suites = null
ssl.key.password = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.provider = null
sasl.kerberos.service.name = null
session.timeout.ms = 40000
sasl.kerberos.ticket.renew.window.factor = 0.8
bootstrap.servers = [server-name:9092]
client.id = 
fetch.max.wait.ms = 500
fetch.min.bytes = 50000
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
sasl.kerberos.kinit.cmd = /usr/bin/kinit
auto.offset.reset = latest
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
ssl.endpoint.identification.algorithm = null
max.partition.fetch.bytes = 2097152
ssl.keystore.location = null
ssl.truststore.location = null
ssl.keystore.password = null
metrics.sample.window.ms = 30000
metadata.max.age.ms = 300000
security.protocol = PLAINTEXT
auto.commit.interval.ms = 5000
ssl.protocol = TLS
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
ssl.trustmanager.algorithm = PKIX
group.id = test7
enable.auto.commit = false
metric.reporters = []
ssl.truststore.type = JKS
send.buffer.bytes = 131072
reconnect.backoff.ms = 50
metrics.num.samples = 2
ssl.keystore.type = JKS
heartbeat.interval.ms = 3000

Exception in thread "main" org.apache.kafka.commun.KafkaException:
Impossible de construire kafka consommateur au
org.apache.kafka.clients.à la consommation.KafkaConsumer.(KafkaConsumer.java:624)
au
org.apache.kafka.clients.à la consommation.KafkaConsumer.(KafkaConsumer.java:518)
au
org.apache.kafka.clients.à la consommation.KafkaConsumer.(KafkaConsumer.java:500)

Vous pouvez poster l'ensemble de la pile d'erreur? il n'y a pas assez de détails pour vous aider ici.

OriginalL'auteur Deeps | 2016-07-15

apache-kafka

12

La gamme de la consommation d'expiration de la session est contrôlée par le courtier group.max.session.timeout.ms(par défaut 30) et group.min.session.timeout.ms(par défaut 6).

Vous devez augmenter groupe.max.session.délai d'attente.mme premier broker côté, sinon vous obtiendrez "Le délai d'expiration de session n'est pas dans une plage acceptable.".

Merci, mais l'ajout de/groupe de paramètres.max.session.délai d'attente.ms=3600000 dans config/serveur.propriétés n'est toujours pas à résoudre ce problème. Mais maintenant je suis arriver "Causé par: org.apache.kafka.commun.config.ConfigException: demande.délai d'attente.ms doit être supérieure à celle de la session.délai d'attente.ms et d'extraction.max.attendre.ms", erreur qui est utile.
Cela a fonctionné après le réglage de la demande.délai d'attente.ms à une valeur supérieure à la session.délai d'attente.ms.

OriginalL'auteur Shawn Guo
9
- Ces conditions doivent être garder à l'esprit pour changer de session.délai d'attente.ms:
  1. groupe.max.session.délai d'attente.ms dans le serveur.propriétés > session.délai d'attente.ms dans la consommation.les propriétés.
  2. groupe.min.session.délai d'attente.ms dans le serveur.propriétés < session.délai d'attente.ms dans la consommation.les propriétés.
  3. demande.délai d'attente.ms > session.délai d'attente.ms et d'extraction.max.attendre.ms
  4. (session.délai d'attente.ms)/3 > battement de coeur.d'intervalle.ms
  5. session.délai d'attente.ms > Pire des cas, le délai de traitement des Dossiers des Consommateurs par le consommateur sondage(ms).
OriginalL'auteur preetham

je suis à l'aide de printemps-kafka

j'avais ajouté à la suite de la configuration, mais le consommateur n'était pas encore en place:

buildProperties.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, env.getProperty("kafka.user-events-min-bytes"));
    buildProperties.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, env.getProperty("kafka.user-events-wait-time-ms") );
    buildProperties.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, env.getProperty("kafka.user-events-wait-time-ms") );
    buildProperties.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, env.getProperty("kafka.user-events-request-timeout-ms"));
    buildProperties.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, env.getProperty("kafka.user-events-wait-time-ms"));

j'ai compris qu'il n'était pas à cause de sondage.délai d'attente était de 1000;
ajouter la configuration suivante aidé:

factory.getContainerProperties().setPollTimeout(Integer.parseInt(env.getProperty("kafka.user-events-wait-time-ms")));

OriginalL'auteur Salona Sinha

Vous devez vous connecter pour publier un commentaire.