Hello All,

I am using Kafka-clients-4.1.1.jar with a kafka broker that is on version
4.0.0. From my Java code, when I call the KafkaConsumer partitionsFor API,
I see that it works when the topic is already created in kafka. But if it
is not yet created, the above API call returns empty - no information.

I noticed that just before I call partitionsFor API, the topic is not
created. But after I call this API, the topic gets created, but this API
still returns no information. Of course, if I call the same API again, I do
get valid information for this topic.

I used to have kafka-clients-3.9.0.jar earlier. There both these cases were
working fine. Is this a new change in behavior in kafka-clients-4.1.1.jar?

Thanks,
Anand

Reply via email to