It seems like we definitely shouldn't block indefinitely, but what is probably happening is that the consumer is fetching metadata, not finding the topic, then getting hung up somewhere.
It probably won't hang indefinitely -- there is a periodic refresh of metadata, defaulting to every 5 minutes, which should pick up the topic once you have created it. Presumably then it would start returning data. -Ewen On Mon, Aug 1, 2016 at 4:31 PM, Carlos Rodriguez Fernandez < carlosrodrifernan...@gmail.com> wrote: > Hi, > When using Apache Camel Kafka to consume messages, I notice that when the > topic is not created the fetching here: > > org.apache.camel.component.kafka.KafkaConsumer.run.. > > ConsumerRecords<Object, Object> records = consumer.poll(Long.MAX_VALUE); > > > ... just hangs forever, even if I create the topic and publish messages. It > seems that I need to create the topic *before* the "poll" is invoked, > otherwise, the poll call never comes back not matter what I do. > > > Is this an expected behaviors? > > > Thank you, > > Carlos. > -- Thanks, Ewen
