aio-libs / aio-libs/aiokafka

Admin client: list offsets per topic/partition

Abierto
#1,045 1 comentario 0 reacciones 0 asignados Ver en GitHub
enhancement
Lenguaje dominante
Python
Estrellas
1.4k
Forks
269
Merge medio
1 d 1 h
PR fusionados (30 d)
6

Descripción

**Describe the solution you'd like**
A new function in the admin client that lets me retrieve the offsets (earliest/latest) of each partition.

**Additional context**
Confluent's admin client has [list_offsets](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/_modules/confluent_kafka/admin.html#AdminClient.list_offsets).

My use case is retrieving the number of messages behind per consumer-group/topic. `list_consumer_group_offsets` provides the offsets per consumer group, and I need the offset of the latest messages.

Guía de contribución

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.