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?
source share