Problem solved!
I had to reconfigure some brokers, to cleanup the configuration and
metadata in __consumer offset.
Thanks Jason
On 26/04/16 23:06, Jason Gustafson wrote:
Hey Jose,
That error could indicate that one of the partitions of the
__consumer_offsets topic has no leader. The group
Hey Jose,
That error could indicate that one of the partitions of the
__consumer_offsets topic has no leader. The group coordinators are chosen
from the leaders of those partitions, so if one is unavailable, then the
consumer won't be able to find the group. Can you show the output of the
followin
That is the problem,
I can't see the stack trace, the KafkaConsumer don't throw any
Exception, it simply stay in *poll() *method and never return. I
realized the internal error was GroupCoordinatorNotAvailableException by
using Kafka from source code and tracing the method calls, I saw that
Hi Jose,
Can you provide the full exception stack trace? Which method is this being
throw from? It might help to see the snippet which is producing it as well.
Thanks,
Jason
On Tue, Apr 26, 2016 at 5:19 AM, Jose Raul Perez Rodriguez <
joseraul.w...@gmail.com> wrote:
> Hello,
>
> I am using Kafk
Hello,
I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the
producer works good (the Console Consumer provided in samples receives
the producer data).
But in the configured KafkaConsumer I got the
/org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error
T
Hello,
I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the
producer works good (the Console Consumer provided in samples receives
the producer data).
But in the configured KafkaConsumer I got the
/org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error
T
Hello,
I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the
producer works good (the Console Consumer provided in samples receives
the producer data).
But in the configured KafkaConsumer I got the
/org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error
