You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently, the AIOKafkaConsumer class has no way to set the client.rack consumer config supported by other clients.
Adding and implementing this option would allow consumers to fetch from the nearest replica.
trentbitterman
changed the title
Add client.rack configuration option to support consumer fetching from closest replica
Add client.rack configuration option to support consumer fetching from closest replica (KIP-392)
Jul 2, 2024
Describe the solution you'd like
Currently, the
AIOKafkaConsumer
class has no way to set theclient.rack
consumer config supported by other clients.Adding and implementing this option would allow consumers to fetch from the nearest replica.
Additional context
More information can be found in KIP-392.
This configuration value is supported by librdkafka and confluent-kafka-python, for example.
The text was updated successfully, but these errors were encountered: