aio-libs / aio-libs/aiokafka

Add compability with OpenTelemetry

Abierto
#862 3 comentarios 2 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**
Currently, there's no clear way to export metrics or traces running directly from the program.
Opentelemetry allows `auto instrumentation` with [this python package](https://github.com/open-telemetry/opentelemetry-python-contrib/blob/ebe6d1804bccff184edb379d7780469762c7b854/instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/__init__.py). If we use sync `kafka-python` it's possible to export traces by just adding `KafkaInstrumentor().instrument()`, in `Jaeger` this is how they look.

![image](https://user-images.githubusercontent.com/53630064/197703936-c2c0a8c5-a73e-463f-a082-4a6e2abd5e44.png)

However, this will not work with the current implementation of `aiokafka`

I could start the conversation over there as well, however, I think they won't be able to include `aiokafka` since it -unfortunately- does not exposed metrics

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.