Description
Hi all,
I'm working with Kafka in some projects, building Kafka clusters in which a producer sends messages to the broker that has the leader partition and a subscribers must read the messages from a follower partition (ie. from other Kafka broker). For that purpose, I am aware of KIP-392 to allow consumers to fetch from closest replica, which solves my problem, and I was also able to test that functionality with native Kafka consumers deployed with Kafka commands. However, I was wondering if this functionality is also enabled on the kafka-python library, because I have not found anything in the documentation related to this. Mainly, what I need is to indicate the "client.rack" property when creating a Python Kafka Consumer, so that I can ensure that the consumer will read from the proper broker and not from the leader. Is there any workaround to do this? Or is it planned to be added to the code?
Thank you very much in advance.