Hi Jaikiran, You are correct - I assumed it was a consumer setting and it is a broker setting.
The consumer quietly took the broker setting and didn't throw an exception, and when trying to set my session timeout above the broker's allowed max the error message given is very poor. If it would have said something like "The consumer's session timeout must be between the min and max group timeout set on the broker" I would have known immediately. Leaving this reply here for anyone who might make the same mistake. Thanks for the help! -----Original Message----- From: Jaikiran Pai [mailto:jai.forums2...@gmail.com] Sent: Tuesday, May 3, 2016 10:47 PM To: users@kafka.apache.org Subject: Re: Receiving "The session timeout is not within an acceptable range" but AFAIK it is within range 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.StringSerialize > r > value.deserializer=org.apache.kafka.common.serialization.StringDeseria > lizer > key.serializer=org.apache.kafka.common.serialization.StringSerializer > key.deserializer=org.apache.kafka.common.serialization.StringDeseriali > zer > 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 >
