kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kevin Sjöberg <kevin.sjob...@fortnox.se>
Subject Using SimpleConsumer to get messages from offset until now
Date Tue, 02 Jun 2015 16:25:37 GMT

I'm trying to create a custom consumer that given a offset returns all
messages until now. After this is done, the consumer is not needed anymore,
hence, the consumer does not have to continue consuming messages that are
being produced.

The Kafka cluster exists of one broker and we only use one partition as
well. My understanding is that I can use the SimpleConsumer API for this,
but I'm a bit unsure on how to go about it.

Would anyone mind helping me out or point me in the right direction?


Kevin Sjöberg

Du skapar din faktura, vi skickar den och ser till att kunden betalar. Vi 
sköter allt, hela vägen tills fakturan är betald! 
Läs om Nox Finans här 

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message