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
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
Comments
Post a Comment