add trace logging for kafka headers

base/mqueue/mqueue_impl_gokafka.go

@@ -15,6 +15,7 @@ import (
 	"github.com/segmentio/kafka-go/sasl"
 	kafkaPlain "github.com/segmentio/kafka-go/sasl/plain"
 	kafkaScram "github.com/segmentio/kafka-go/sasl/scram"
+	log "github.com/sirupsen/logrus"
 )
 
 type kafkaGoReaderImpl struct {
@@ -31,6 +32,11 @@ func (t *kafkaGoReaderImpl) HandleMessages(handler MessageHandler) {
 			utils.LogError("err", err.Error(), "unable to read message from Kafka reader")
 			panic(err)
 		}
+		if !log.IsLevelEnabled(log.TraceLevel) {
+			for _, h := range m.Headers {
+				utils.LogTrace("key", h.Key, "value", string(h.Value), "kafka message header")
+			}
+		}
 		// At this level, all errors are fatal
 		kafkaMessage := KafkaMessage{Key: m.Key, Value: m.Value}
 		if err = handler(kafkaMessage); err != nil {