From what you pasted, I can't say for certain whether you are using
those properties as consumer level settings or broker level settings.
The group.min.session.timeout.ms and the group.max.session.timeout.ms
are broker level settings (as far as I understand) and should be part of
your broker config (server.properties). Using them in consumer level
settings while creating the consumer, will result in those properties
being ignored. Can you confirm where exactly you have set those values?
-Jaikiran
On Tuesday 03 May 2016 11:25 PM, Mario Ricci wrote:
Hi all,
This seems like a basic question and I am probably just missing something, but when
creating my consumer I am getting the error: "The session timeout is not within an
acceptable range"
My settings seem to be good (group.max and group.min don't violate
session.timeout).
Here are my settings:
request.timeout.ms=121000
session.timeout.ms=30001
group.min.session.timeout.ms=6000
group.max.session.timeout.ms=120000
receive.buffer.bytes=262144
group.id=consumeproduce
auto.offset.reset=earliest
offsets.storage=zookeeper
bootstrap.servers=10.7.52.170:9092
dual.commit.enabled=true
max.partition.fetch.bytes=2097152
enable.auto.commit=false
value.serializer=org.apache.kafka.common.serialization.StringSerializer
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
key.serializer=org.apache.kafka.common.serialization.StringSerializer
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
fetch.min.bytes=50000
and here is the code I believe that throws the error:
else if (sessionTimeoutMs < groupConfig.groupMinSessionTimeoutMs ||
sessionTimeoutMs > groupConfig.groupMaxSessionTimeoutMs) {
responseCallback(joinError(memberId,
Errors.INVALID_SESSION_TIMEOUT.code))
I see that the error should not be thrown, though. Can anyone please help? As
soon as I get over 30000 ms for session.timeout.ms I get that error. I know
previously I have had it much higher.
Mario
