I can reproduce this on 0.9.0.0. The error log is
[2016-01-28 16:12:32,840] ERROR [Replica Manager on Broker 1]: Error
processing fetch operation on partition [ad-events,1] offset 75510318
(kafka.server.ReplicaManager)
I also print the sent offset from producer
time partition offset
16:12:32.8
Yes, I've asked the user to test with the 0.9.0.0 release (I saw Gwen's
comment in KAFKA-725).
I have a potentially related question: Is it an issue that both Flink and
Gearpump* are not committing their offsets through the SimpleConsumer API?
Flink is directly committing the offsets into ZK (and
Hi Manu and Robert,
It would help to know if this still happens in trunk or the 0.9.0 branch.
Ismael
On 27 Jan 2016 13:05, "Robert Metzger" wrote:
> Hi Manu,
>
> in the streaming-benchmark, are seeing the issue only when reading with
> Gearpump, or is it triggered by a different processing fram
Hi Manu,
in the streaming-benchmark, are seeing the issue only when reading with
Gearpump, or is it triggered by a different processing framework as well?
I'm asking because there is a Flink user who is using Kafka 0.8.2.1 as well
who's reporting a very similar issue on SO:
http://stackoverflow.c
Hi,
Any suggestions for this issue or do I need to provide more information ?
Any links I can refer to would be also very helpful.
Thanks,
Manu Zhang
On Tue, Jan 19, 2016 at 8:41 PM, Manu Zhang wrote:
> Hi all,
>
> Is KAFKA-725 Broker Exception: Attempt to read with a maximum offset less
> th
