You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Ratha v <vi...@gmail.com> on 2016/03/29 05:54:24 UTC
java.lang.IllegalArgumentException: Heartbeat must be set lower than
the session timeout
Hi all;
When i try to create my consumer from the properties, i get above exception.
Can anybody point me what property i set wrong?
kafka 0.9.x version.
*code*
import org.apache.kafka.clients.consumer.KafkaConsumer;
public ListenerThread(List<String> topics, Properties properties) {
this.consumer = new KafkaConsumer<>(properties);
this.topics = topics;
}
*Error*
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed
to construct kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:518)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:500)
at com.xx.ListenerThread.<init>(ListenerThread.java:34)
at com.xx..MessageListener.start(MessageListener.java:108)
at com.xxx.MessageListener.main(MessageListener.java:147)
Caused by: java.lang.IllegalArgumentException: Heartbeat must be set lower
than the session timeout
at
org.apache.kafka.clients.consumer.internals.Heartbeat.<init>(Heartbeat.java:30)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.<init>(AbstractCoordinator.java:122)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.<init>(ConsumerCoordinator.java:92)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:569)
Thanks
--
-Ratha
http://vvratha.blogspot.com/
RE: java.lang.IllegalArgumentException: Heartbeat must be set lower
than the session timeout
Posted by Martin Gainty <mg...@hotmail.com>.
MG>what are the mathematical checks between Kafka session.timeout.ms and Tomcat session-timeout in web.xml?<session-config>
<session-timeout>1</session-timeout> <!-- 1 minutes -->
</session-config>
MG>Thank You
MG>Martin
> Date: Tue, 29 Mar 2016 15:07:22 +1100
> Subject: Re: java.lang.IllegalArgumentException: Heartbeat must be set lower than the session timeout
> From: vijayaratha@gmail.com
> To: users@kafka.apache.org
>
> I overcame this issue with the property "heartbeat.interval.ms"..
>
> Thanks.
>
> On 29 March 2016 at 14:54, Ratha v <vi...@gmail.com> wrote:
>
> > Hi all;
> > When i try to create my consumer from the properties, i get above
> > exception.
> > Can anybody point me what property i set wrong?
> >
> >
> > kafka 0.9.x version.
> >
> >
> > *code*
> >
> > import org.apache.kafka.clients.consumer.KafkaConsumer;
> >
> >
> > public ListenerThread(List<String> topics, Properties properties) {
> >
> > this.consumer = new KafkaConsumer<>(properties);
> >
> > this.topics = topics;
> >
> > }
> >
> >
> > *Error*
> >
> > Exception in thread "main" org.apache.kafka.common.KafkaException: Failed
> > to construct kafka consumer
> >
> > at
> > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624)
> >
> > at
> > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:518)
> >
> > at
> > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:500)
> >
> > at com.xx.ListenerThread.<init>(ListenerThread.java:34)
> >
> > at com.xx..MessageListener.start(MessageListener.java:108)
> >
> > at com.xxx.MessageListener.main(MessageListener.java:147)
> >
> > Caused by: java.lang.IllegalArgumentException: Heartbeat must be set lower
> > than the session timeout
> >
> > at
> > org.apache.kafka.clients.consumer.internals.Heartbeat.<init>(Heartbeat.java:30)
> >
> > at
> > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.<init>(AbstractCoordinator.java:122)
> >
> > at
> > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.<init>(ConsumerCoordinator.java:92)
> >
> > at
> > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:569)
> >
> > Thanks
> > --
> > -Ratha
> > http://vvratha.blogspot.com/
> >
>
>
>
> --
> -Ratha
> http://vvratha.blogspot.com/
Re: java.lang.IllegalArgumentException: Heartbeat must be set lower
than the session timeout
Posted by Ratha v <vi...@gmail.com>.
I overcame this issue with the property "heartbeat.interval.ms"..
Thanks.
On 29 March 2016 at 14:54, Ratha v <vi...@gmail.com> wrote:
> Hi all;
> When i try to create my consumer from the properties, i get above
> exception.
> Can anybody point me what property i set wrong?
>
>
> kafka 0.9.x version.
>
>
> *code*
>
> import org.apache.kafka.clients.consumer.KafkaConsumer;
>
>
> public ListenerThread(List<String> topics, Properties properties) {
>
> this.consumer = new KafkaConsumer<>(properties);
>
> this.topics = topics;
>
> }
>
>
> *Error*
>
> Exception in thread "main" org.apache.kafka.common.KafkaException: Failed
> to construct kafka consumer
>
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624)
>
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:518)
>
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:500)
>
> at com.xx.ListenerThread.<init>(ListenerThread.java:34)
>
> at com.xx..MessageListener.start(MessageListener.java:108)
>
> at com.xxx.MessageListener.main(MessageListener.java:147)
>
> Caused by: java.lang.IllegalArgumentException: Heartbeat must be set lower
> than the session timeout
>
> at
> org.apache.kafka.clients.consumer.internals.Heartbeat.<init>(Heartbeat.java:30)
>
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.<init>(AbstractCoordinator.java:122)
>
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.<init>(ConsumerCoordinator.java:92)
>
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:569)
>
>
> Thanks
> --
> -Ratha
> http://vvratha.blogspot.com/
>
--
-Ratha
http://vvratha.blogspot.com/