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/
