From ffdb65291104564e83570804a5b907efb72a0a3b Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Mon, 6 Feb 2023 16:33:54 +0800 Subject: [PATCH] Fix kafka ut (#21943) Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/mq/msgstream/mqwrapper/kafka/kafka_message_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/mq/msgstream/mqwrapper/kafka/kafka_message_test.go b/internal/mq/msgstream/mqwrapper/kafka/kafka_message_test.go index 90f407a171..3fd9363251 100644 --- a/internal/mq/msgstream/mqwrapper/kafka/kafka_message_test.go +++ b/internal/mq/msgstream/mqwrapper/kafka/kafka_message_test.go @@ -11,8 +11,9 @@ func TestKafkaMessage_All(t *testing.T) { topic := "t" msg := &kafka.Message{TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: 0, Offset: 0}, Value: nil, Headers: nil} km := &kafkaMessage{msg: msg} + properties := make(map[string]string) assert.Equal(t, topic, km.Topic()) assert.Equal(t, int64(0), km.ID().(*kafkaID).messageID) assert.Nil(t, km.Payload()) - assert.Nil(t, km.Properties()) + assert.Equal(t, properties, km.Properties()) }