After a bit more looking into this we found out that the Offsetmanager is single threaded and due to our setup (few, powerful servers: rather bad for kafka I know..) it seems we are limiting ourselves severely by using kafka offsets.

Any more insight is still welcome of course.


-------- Forwarded Message --------
Subject:        unknown (kafka) offsets after restart
Date:   Fri, 6 May 2016 14:12:24 +0200
From:   Jörg Wagner <joerg.wagn...@1und1.de>
Reply-To:       users@kafka.apache.org
To:     users@kafka.apache.org



We're using Kafka 0.8.2 and are puzzled by the offset behaviour when
they are stored in kafka topics.

Upon restart of the Kafka cluster (e.g. due to reconfiguration) it can
happen that the offsets are unknown and therefore stop consumers from
consuming without knowing their offset.

kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group group
--zookeeper localhost:2181
Could not fetch offset for [topic,19] due to
kafka.common.OffsetsLoadInProgressException.

Group           Topic                          Pid Offset
logSize         Lag             Owner
group   topic    0   unknown         326606          unknown none

I currently have no other solution to this than to wait.. but it takes a
very long time (hours.. the servers are hopelessly underutilized!), I
would be grateful for any advice.

Thanks
Jörg



Reply via email to