From e28143ec0803a6c5c21aca846163732d4516d792 Mon Sep 17 00:00:00 2001
From: Eray Arslan <relfishere@gmail.com>
Date: Thu, 5 Sep 2024 14:20:00 +0300
Subject: [PATCH] feat: print kafka config

---
 connector.go | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/connector.go b/connector.go
index 7091690..e74e5c7 100644
--- a/connector.go
+++ b/connector.go
@@ -1,10 +1,14 @@
 package dcpkafka
 
 import (
+	"bytes"
+	"encoding/json"
 	"errors"
 	"fmt"
 	"os"
 
+	jsoniter "github.com/json-iterator/go"
+
 	dcpCouchbase "github.com/Trendyol/go-dcp/couchbase"
 
 	"github.com/Trendyol/go-dcp/helpers"
@@ -142,6 +146,9 @@ func newConnector(cfg any, mapper Mapper, sinkResponseHandler kafka.SinkResponse
 		return nil, err
 	}
 
+	copyOfConfig := c.Kafka
+	printConfiguration(copyOfConfig)
+
 	conf := dcpClient.GetConfig()
 	conf.Checkpoint.Type = "manual"
 
@@ -260,3 +267,16 @@ func (c *ConnectorBuilder) SetLogger(l *logrus.Logger) *ConnectorBuilder {
 	}
 	return c
 }
+
+func printConfiguration(config config.Kafka) {
+	config.ScramPassword = "*****"
+	configJSON, _ := jsoniter.Marshal(config)
+
+	dst := &bytes.Buffer{}
+	if err := json.Compact(dst, configJSON); err != nil {
+		logger.Log.Error("error while print kafka configuration, err: %v", err)
+		panic(err)
+	}
+
+	logger.Log.Info("using kafka config: %v", dst.String())
+}