feat: get topic name on producer

Signed-off-by: Eray Ates <[email protected]>

client.go

@@ -327,3 +327,7 @@ func (c *Client) Skip(modify func(SkipMap) SkipMap) {
 
 	c.logger.Debug("wkafka skip modified", "skip", c.consumerConfig.Skip)
 }
+
+func (c *Client) GetClientID() []byte {
+	return c.clientID
+}

producer.go

@@ -8,7 +8,7 @@ import (
 	"github.com/twmb/franz-go/pkg/kgo"
 )
 
-var defaultServiceNameKey = "service"
+const HeaderServiceKey = "service"
 
 type (
 	Header = kgo.RecordHeader
@@ -94,7 +94,7 @@ func NewProducer[T any](client *Client, topic string, opts ...OptionProducer) (*
 		Topic: topic,
 		Headers: []Header{
 			{
-				Key:   defaultServiceNameKey,
+				Key:   HeaderServiceKey,
 				Value: client.clientID,
 			},
 		},
@@ -116,6 +116,11 @@ type Producer[T any] struct {
 	produceRaw func(ctx context.Context, records []*Record) error
 }
 
+// GetTopic to get producer default topic.
+func (p *Producer[T]) GetTopic() string {
+	return p.config.Topic
+}
+
 func (p *Producer[T]) Produce(ctx context.Context, data ...T) error {
 	records := make([]*Record, 0, len(data))
 

producerdlq_test.go

@@ -69,7 +69,7 @@ func Test_producerDLQ(t *testing.T) {
 
 			for _, header := range records[i].Headers {
 				switch header.Key {
-				case defaultServiceNameKey:
+				case HeaderServiceKey:
 					assert.Equal(t, clientID, header.Value)
 				case "error":
 					assert.Equal(t, errDLQStr, string(header.Value))