fix format issue

aws · Jul 23, 2021 · 5d6f36f · 5d6f36f
1 parent 20a2917
commit 5d6f36f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 13 deletions.
diff --git a/events/kafka.go b/events/kafka.go
@@ -3,19 +3,19 @@
 package events
 
 type KafkaEvent struct {
-	EventSource    	 string                   `json:"eventSource"`
-	EventSourceARN 	 string                   `json:"eventSourceArn"`
-	Records        	 map[string][]KafkaRecord `json:"records"`
-	BootstrapServers string 				  `json:"bootstrapServers"`
+	EventSource      string                   `json:"eventSource"`
+	EventSourceARN   string                   `json:"eventSourceArn"`
+	Records          map[string][]KafkaRecord `json:"records"`
+	BootstrapServers string                   `json:"bootstrapServers"`
 }
 
 type KafkaRecord struct {
-	Topic         string                	`json:"topic"`
-	Partition     int64                 	`json:"partition"`
-	Offset        int64                 	`json:"offset"`
-	Timestamp     MilliSecondsEpochTime 	`json:"timestamp"`
-	TimestampType string                	`json:"timestampType"`
-	Key           string                	`json:"key,omitempty"`
-	Value         string                	`json:"value,omitempty"`
-	Headers		  []map[string][]byte		`json:"headers"`
+	Topic         string                `json:"topic"`
+	Partition     int64                 `json:"partition"`
+	Offset        int64                 `json:"offset"`
+	Timestamp     MilliSecondsEpochTime `json:"timestamp"`
+	TimestampType string                `json:"timestampType"`
+	Key           string                `json:"key,omitempty"`
+	Value         string                `json:"value,omitempty"`
+	Headers       []map[string][]byte   `json:"headers"`
 }
diff --git a/events/kafka_test.go b/events/kafka_test.go
@@ -29,7 +29,7 @@ func TestKafkaEventMarshaling(t *testing.T) {
 			assert.Equal(t, 2020, utc.Year())
 			assert.Equal(t, record.Key, "OGQ1NTk2YjQtMTgxMy00MjM4LWIyNGItNmRhZDhlM2QxYzBj")
 			assert.Equal(t, record.Value, "OGQ1NTk2YjQtMTgxMy00MjM4LWIyNGItNmRhZDhlM2QxYzBj")
-			
+
 			for _, header := range record.Headers {
 				for key, value := range header {
 					assert.Equal(t, key, "headerKey")