Kafka consumer does not receive messages until restart

I tried both Kafka 0.8.2.2 and 0.9.0.0, and I see the same problem on both, which is:

I start the new Zookeeper and Kafka server (empty data / log directories), start the consumer process for "mytopic", start the creation process for "mytopic", and then send the message through the manufacturer. The consumer does not receive the message until it is restarted.

I tried to configure the user with both the earliest and the “latest” reset consumer bias standards.

My question is this expected behavior? If so, then there is a way to change it. If not, what is going on here?

+6
source share
1 answer

If you first start with a topic that does not yet exist, but will be automatically created by the Kafka broker, this may be the same as in this question . Can you try whether the solution mentioned will solve your problem?

-1
source

All Articles