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/