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

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

diff --git a/connector.go b/connector.go
index 13fd0ca..aa93de9 100644
--- a/connector.go
+++ b/connector.go
@@ -1,11 +1,15 @@
 package dcpelasticsearch
 
 import (
+	"bytes"
+	"encoding/json"
 	"errors"
 	"os"
 	"regexp"
 	"strings"
 
+	jsoniter "github.com/json-iterator/go"
+
 	dcpCouchbase "github.com/Trendyol/go-dcp/couchbase"
 
 	"github.com/Trendyol/go-dcp-elasticsearch/elasticsearch/client"
@@ -163,6 +167,9 @@ func newConnector(cf any, mapper Mapper, sinkResponseHandler dcpElasticsearch.Si
 		return nil, err
 	}
 
+	copyOfConfig := cfg.Elasticsearch
+	printConfiguration(copyOfConfig)
+
 	dcpConfig := dcp.GetConfig()
 	dcpConfig.Checkpoint.Type = "manual"
 
@@ -227,3 +234,16 @@ func (c *ConnectorBuilder) SetSinkResponseHandler(sinkResponseHandler dcpElastic
 	c.sinkResponseHandler = sinkResponseHandler
 	return c
 }
+
+func printConfiguration(config config.Elasticsearch) {
+	config.Password = "*****"
+	configJSON, _ := jsoniter.Marshal(config)
+
+	dst := &bytes.Buffer{}
+	if err := json.Compact(dst, configJSON); err != nil {
+		logger.Log.Error("error while print elasticsearch configuration, err: %v", err)
+		panic(err)
+	}
+
+	logger.Log.Info("using elasticsearch config: %v", dst.String())
+}