Hello, I'm having problems with Kafka 0.7:
Here is a project I've put together to show the problem: https://bitbucket.org/agallego/kafkaoffset (make sure to run twice: once to generate data, and one to see the problem. ) I can't seem to get valid offsets from the queue using a SimpleConsumer class. (https://bitbucket.org/agallego/kafkaoffset/src/a9043505919dd8743e368e27467dd96ac0c9c0aa/src/main/java/test/kafka/SampleConsumer.java#cl-13) I can read and write to the queue no problem given an offset. Everything works just fine. However, I want to read from the queue the last offset from 'now()' . That is to say, I want to pass in an arbitrary time in the past and I want to get a list of correct offsets. (off course given that there is data before that time) ** What am I seeing instead ? *** I always get an array of 0's quite literally long[] tmp = {0L, 0L, 0L....} ** What do I expect to see *** An array of valid offsets as stated by the api. Is this a bug ? What am I doing wrong. The whole code is about 20 lines of code. It assumes a running instance of kafka on localhost. (off course you can change it) Thanks in advance Sincerely, Alex ---*--- ------* * * *
