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/
