feat(instrumentation): Support Kafka instrumentation

[tushar1977]

Is there an existing issue for this?

• I have searched the existing issues

Package

I'll start planning and finalize the code structure in next couple of days. will post here for review

Version

No response

Environment

Kafka

Use-case

No response

Telemetry

No response

Anything else?

No response

Tip

_{React with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding +1 or me too, to help us triage it. Learn more here.}

[tushar1977]

hi @kakkoyun @y1yang0 @NameHaibinZhang
Could you please review my KafkaRequest struct for tracing Kafka operations?

type KafkaRequest struct {
	Topic           string  // Topic name
	Operation       string  // Consume | Produce 
	Partition       int  
	Offset          int64
	ConsumerGroupID string   
	MessageKey      string    //Kafka message key
}

Right now, i am implementing segmentio/kafka-go. I have also reviewed the redis implementation PR.

[kakkoyun]

@tushar1977 I'll do my best to review it, this week.

[tushar1977]

@tushar1977 I'll do my best to review it, this week.

actually, i got a review from y1yang0 an working on it. Thanks