kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From eugene miretsky <eugene.miret...@gmail.com>
Subject Retrieving last message offset in high level consumer
Date Thu, 01 Oct 2015 22:36:07 GMT
Hi,

We would like to log the offset of a Kafka message if we fail to process it
(so we can try to re-process it later). Is it possible to get the offset
using the high level consumer?

I took a quick look at the code, and:

   - It seems like the offset it private in the current Scala consumer
   (ConsumerIterator.scala)
   - The offset is exposed by the API of the new Java consumer
   (KafkaConsumer.java)


Would it make sense to expose the offset in the  Scala consumer as well?

Cheers,
Eugene

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