Used headerLen

klaytn · Jun 29, 2021 · f3305b8 · f3305b8
1 parent d8c9ed7
commit f3305b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datasync/chaindatafetcher/kafka/consumer.go b/datasync/chaindatafetcher/kafka/consumer.go
@@ -76,7 +76,7 @@ func newSegment(msg *sarama.ConsumerMessage) (*Segment, error) {
 	version := ""
 	producerId := ""
 
-	if len(msg.Headers) == MsgHeaderLength {
+	if headerLen == MsgHeaderLength {
 		keyVersion := string(msg.Headers[MsgHeaderVersion].Key)
 		if keyVersion != KeyVersion {
 			return nil, fmt.Errorf("%v [expected: %v, actual: %v]", wrongHeaderKeyErrorMsg, KeyVersion, keyVersion)