From 78df560a50e0d17722432870265d27336a2b62ce Mon Sep 17 00:00:00 2001 From: crossoverJie Date: Fri, 1 Nov 2024 18:28:25 +0800 Subject: [PATCH] remove unless test code --- pulsar/consumer_test.go | 9 --------- 1 file changed, 9 deletions(-) diff --git a/pulsar/consumer_test.go b/pulsar/consumer_test.go index 8c1aed17e..d8f31458f 100644 --- a/pulsar/consumer_test.go +++ b/pulsar/consumer_test.go @@ -4727,10 +4727,6 @@ func TestLookupConsumer(t *testing.T) { for i := 0; i < 10; i++ { if _, err := producer.Send(ctx, &ProducerMessage{ Payload: []byte(fmt.Sprintf("hello-%d", i)), - Key: "pulsar", - Properties: map[string]string{ - "key-1": "pulsar-1", - }, }); err != nil { log.Fatal(err) } @@ -4744,12 +4740,7 @@ func TestLookupConsumer(t *testing.T) { } expectMsg := fmt.Sprintf("hello-%d", i) - expectProperties := map[string]string{ - "key-1": "pulsar-1", - } assert.Equal(t, []byte(expectMsg), msg.Payload()) - assert.Equal(t, "pulsar", msg.Key()) - assert.Equal(t, expectProperties, msg.Properties()) // ack message consumer.Ack(msg) }