[confluent-kafka] Add wrapper to 'consume' method for batch messages

[faunris]

Is your feature request related to a problem?
If we use consumer.consume(num_messages=100) src for receiving messages, ConfluentKafkaInstrumentor doesn't send spans for this.

Describe the solution you'd like
ConfluentKafkaInstrumentor should wrap consume method the same as the poll method.

Additional context
We could add messaging.batch.message_count to semconv and use it in a span tag. Relates to batch-receiving in opentelemetry-semantic-conventions.

[javferrod]

Hi! It seems like a good issue to start contributing. Can I take it?

The addition of messaging.batch.message_count needs the v1.17.0 of semconv. I cannot add it until this PR is merged, but I can wrap the consume method using the same implementation of poll wrapper if that's okay.

[javferrod]

Hi! I opened the PR that fixes this issue a bit ago. How may I help to get it merged?

[Samira-El]

Hi, any updates on this? This will be great to have

[javferrod]

Hi @Samira-El, the PR should be ready. I think it could be merged if @ocelotl is happy with the changes.