From 6324b532ce9a46b7dd17d13b33504b9fb967bd44 Mon Sep 17 00:00:00 2001
From: "adem.ekici" <ademekici90@gmail.com>
Date: Mon, 23 Dec 2024 18:25:07 +0300
Subject: [PATCH] style: fix indentation and formatting for README

---
 README.md | 86 +++++++++++++++++++++++++++----------------------------
 1 file changed, 43 insertions(+), 43 deletions(-)

diff --git a/README.md b/README.md
index 560a2f5..d3aee9e 100644
--- a/README.md
+++ b/README.md
@@ -38,51 +38,51 @@ used for both connectors.
 
 ```go
 func mapper(event couchbase.Event) []message.KafkaMessage {
-// return nil if you wish to discard the event
-return []message.KafkaMessage{
-{
-Headers: nil,
-Key:     event.Key,
-Value:   event.Value,
-},
-}
+	// return nil if you wish to discard the event
+	return []message.KafkaMessage{
+		{
+			Headers: nil,
+			Key:     event.Key,
+			Value:   event.Value,
+		},
+	}
 }
 
 func main() {
-c, err := dcpkafka.NewConnector(&config.Connector{
-Dcp: dcpConfig.Dcp{
-Hosts:      []string{"localhost:8091"},
-Username:   "user",
-Password:   "password",
-BucketName: "dcp-test",
-Dcp: dcpConfig.ExternalDcp{
-Group: dcpConfig.DCPGroup{
-Name: "groupName",
-Membership: dcpConfig.DCPGroupMembership{
-RebalanceDelay: 3 * time.Second,
-},
-},
-},
-Metadata: dcpConfig.Metadata{
-Config: map[string]string{
-"bucket":     "checkpoint-bucket-name",
-"scope":      "_default",
-"collection": "_default",
-},
-Type: "couchbase",
-},
-Debug: true},
-Kafka: config.Kafka{
-CollectionTopicMapping: map[string]string{"_default": "topic"},
-Brokers:                []string{"localhost:9092"},
-},
-}, mapper)
-if err != nil {
-panic(err)
-}
-
-defer c.Close()
-c.Start()
+	c, err := dcpkafka.NewConnector(&config.Connector{
+		Dcp: dcpConfig.Dcp{
+			Hosts:      []string{"localhost:8091"},
+			Username:   "user",
+			Password:   "password",
+			BucketName: "dcp-test",
+			Dcp: dcpConfig.ExternalDcp{
+				Group: dcpConfig.DCPGroup{
+					Name: "groupName",
+					Membership: dcpConfig.DCPGroupMembership{
+						RebalanceDelay: 3 * time.Second,
+					},
+				},
+			},
+			Metadata: dcpConfig.Metadata{
+				Config: map[string]string{
+					"bucket":     "checkpoint-bucket-name",
+					"scope":      "_default",
+					"collection": "_default",
+				},
+				Type: "couchbase",
+			},
+			Debug: true},
+		Kafka: config.Kafka{
+			CollectionTopicMapping: map[string]string{"_default": "topic"},
+			Brokers:                []string{"localhost:9092"},
+		},
+	}, mapper)
+	if err != nil {
+		panic(err)
+	}
+
+	defer c.Close()
+	c.Start()
 }
 ```
 
@@ -139,7 +139,7 @@ Check out on [go-dcp](https://github.com/Trendyol/go-dcp#configuration)
 | cbgo_kafka_connector_batch_produce_latency_ms_current | Time to produce messages in the batch. | N/A    | Gauge      |
 
 You can also use all DCP-related metrics explained [here](https://github.com/Trendyol/go-dcp#exposed-metrics).
-All DCP-related metrics are automatically injected. It means you don't need to do anything.
+All DCP-related metrics are automatically injected. It means you don't need to do anything. 
 
 ## Breaking Changes