aio-libs / aio-libs/aiokafka

Add client.rack configuration option to support consumer fetching from closest replica (KIP-392)

Aberta
#1,016 2 comentários 7 reações 0 responsáveis Ver no GitHub
enhancement
Linguagem predominante
Python
Estrelas
1.4k
Forks
269
Merge médio
1d 1h
PRs com merge (30d)
6

Descrição

**Describe the solution you'd like**

Currently, the `AIOKafkaConsumer` class has no way to set the [`client.rack` consumer config](https://kafka.apache.org/documentation.html#consumerconfigs_client.rack) 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](https://cwiki.apache.org/confluence/display/KAFKA/KIP-392%3A+Allow+consumers+to+fetch+from+closest+replica).
This configuration value is [supported by librdkafka](https://github.com/confluentinc/librdkafka/blob/bb2843b5ce32c52954fced9b746205c9340bf96f/CONFIGURATION.md?plain=1#L136) and [confluent-kafka-python](https://github.com/confluentinc/confluent-kafka-python), for example.

Guia de contribuição

Abrir o guia de contribuição

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.