confluent-kafka-go
confluent-kafka-go copied to clipboard
[Question] Support of hook / interceptor / middleware for metrics and traces monitoring ?
Description
Hi. I'm building instrument for go SDKs and I'm looking for a way to monitor R.E.D metrics (Rate / Error / Duration) for Kafka producer and consumer.
May I ask if confluent-kafka-go provides built-in mechanism to record, calculate and expose those metrics?
Some similar codes:
- redis: https://github.com/redis/go-redis/blob/d8e3e95866c094700ffc8f7e2705c2b8fb7a3793/redis.go#L31
- another kafka client: https://github.com/IBM/sarama/blob/main/interceptors.go