Hi all, Relating to same issue.
Stackoverflow link: https://stackoverflow.com/questions/44745203/camel-kafka-whats-meant-by-maxpollrecords-configuration <https://stackoverflow.com/questions/44745203/camel-kafka-whats-meant-by-maxpollrecords-configuration> > On Jun 24, 2017, at 10:54 AM, Asiri Liyana Arachchi <[email protected] > <mailto:[email protected]>> wrote: > > Hi all, > > When setting seekTo in configuration to "end" and then calling the > consumer.receive, it will output null because consumer already starting from > the end. I want to get the last message. Can that be done using camel? > > import org.apache.camel.ConsumerTemplate; > import org.apache.camel.Exchange; > import org.apache.camel.component.kafka.KafkaEndpoint; > import org.springframework.beans.factory.annotation.Autowired; > > public class StackOverflow { > > @Autowired > ConsumerTemplate kafkaConsumer; > > public void getLatestMsg() { > KafkaEndpoint kafkaEndpoint = new KafkaEndpoint(); > kafkaEndpoint.getConfiguration().setBrokers("localhost:9092"); > kafkaEndpoint.getConfiguration().setGroupId("AsiriGroup"); > kafkaEndpoint.getConfiguration().setTopic("test"); > Exchange temp = kafkaConsumer.receive(kafkaEndpoint, 12_000); > } > } > > > Stackoverflow link : > https://stackoverflow.com/questions/44732041/using-camel-how-to-get-the-last-message-with-the-latest-offset > > <https://stackoverflow.com/questions/44732041/using-camel-how-to-get-the-last-message-with-the-latest-offset> > > > > Thanks & Regards, > Asiri
