为什么我不能增加 session.timeout.ms?

问题描述

我想增加 session.timeout.ms 以允许更长的时间来处理 poll() 调用之间收到的消息.但是，当我将 session.timeout.ms 更改为高于 30000 的值时，它无法创建 Consumer 对象并引发以下错误.

谁能告诉我为什么我不能增加 session.timeout.ms 值或者我是否遗漏了什么?

0 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig 值:request.timeout.ms = 40000check.crcs = 真retry.backoff.ms = 100ssl.truststore.password = nullssl.keymanager.algorithm = SunX509接收.buffer.bytes = 262144ssl.cipher.suites = nullssl.key.password = nullsasl.kerberos.ticket.renew.jitter = 0.05ssl.provider = 空sasl.kerberos.service.name = nullsession.timeout.ms = 40000sasl.kerberos.ticket.renew.window.factor = 0.8bootstrap.servers = [服务器名称:9092]客户端.id =fetch.max.wait.ms = 500fetch.min.bytes = 50000key.deserializer = 类 org.apache.kafka.common.serialization.StringDeserializersasl.kerberos.kinit.cmd =/usr/bin/kinitauto.offset.reset = 最新value.deserializer = 类 org.apache.kafka.common.serialization.StringDeserializerssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]ssl.endpoint.identification.algorithm = nullmax.partition.fetch.bytes = 2097152ssl.keystore.location = nullssl.truststore.location = nullssl.keystore.password = null指标.sample.window.ms = 30000metadata.max.age.ms = 300000security.protocol = 明文auto.commit.interval.ms = 5000ssl.protocol = TLSsasl.kerberos.min.time.before.relogin = 60000连接数.max.idle.ms = 540000ssl.trustmanager.algorithm = PKIXgroup.id = test7enable.auto.commit = falsemetric.reporters = []ssl.truststore.type = JKSsend.buffer.bytes = 131072reconnect.backoff.ms = 50指标.num.samples = 2ssl.keystore.type = JKSheartbeat.interval.ms = 3000

线程main"org.apache.kafka.common.KafkaException 中的异常:未能在以下位置构建 kafka 消费者org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:624)在org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:518)在org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:500)

解决方案

消费者会话超时的范围由brokergroup.max.session.timeout.ms(默认30s)和group.min.session.timeout.ms(默认 6 秒).

你应该先在broker端增加group.max.session.timeout.ms，否则你会得到会话超时不在可接受范围内.".

I want to increase session.timeout.ms to allow longer time for processing the messages received between poll() calls. However when I change session.timeout.ms to a higher value than 30000, it fails to create Consumer object and throws below error.

Could anyone tell why can't I increase session.timeout.ms value or if I am missing something?

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

解决方案

The range of consumer session timeout is controlled by broker group.max.session.timeout.ms(default 30s) and group.min.session.timeout.ms(default 6s).

You should increase group.max.session.timeout.ms first in broker side, otherwise you will get "The session timeout is not within an acceptable range.".

这篇关于为什么我不能增加 session.timeout.ms?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！