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())
 }