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
