Thanks, Brett. We will work on writing a client to do this for us, then.
Regards,
Ali
On Thu, Nov 23, 2017 at 11:02 PM, Brett Rann
wrote:
> Ah apologies.
>
> Found the KIP where the one I suggested was added:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 122%3A+Add+Reset+Consumer+G
Ah apologies.
Found the KIP where the one I suggested was added:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+tooling
And from the discussion thread link, a couple in to the thread:
Currently the only way for an admin to successfully override offs
Unfortunately, it doesn't have that option in this version of Kafka!
On Thu, Nov 23, 2017 at 9:02 PM, Brett Rann
wrote:
> I don't know about kafka-storm spout, but you could try using
> the kafka-consumer-groups.sh cli to reset the offset. It has
> a --reset-offsets option.
>
> On Thu, Nov 23, 2
I don't know about kafka-storm spout, but you could try using
the kafka-consumer-groups.sh cli to reset the offset. It has
a --reset-offsets option.
On Thu, Nov 23, 2017 at 7:02 PM, Ali Nazemian wrote:
> Hi All,
>
> I am using Kafka 0.10.0.2 and I am not able to upgrade my Kafka version. I
> hav
Hi All,
I am using Kafka 0.10.0.2 and I am not able to upgrade my Kafka version. I
have a situation that after removing Kafka topic, I am getting the
following error in Kafka-Storm Spout client because the offset hasn't been
reset properly. I was wondering how I can reset the offset in the
new-con
