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: vijayara...@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 <vijayara...@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/
