Hi,

Currently under the sarama instrumentation for consuming from Kafka only sarama.Consumer and sarama.PartitionConsumer are supported. There is also sarama.ConsumerGroupHandler which is important for instrumenting consumer group consumers.

Since we are using Watermill as a wrapper to our Kafka consuming we don't get traces for kafka.consume since it wraps the consumer group handler when a consumer group is used.

There is a reference implementation in the OTEL Go repo which I use locally and I could contribute to this repo.