chore: since go1.20 initialize a random seed is deprecated

Author: miton18

.gitignore

@@ -14,3 +14,5 @@ coverage.html
 perf/perf
 pulsar-perf
 bin
+
+vendor/

pulsar/message_chunking_test.go

@@ -57,8 +57,6 @@ func TestInvalidChunkingConfig(t *testing.T) {
 }
 
 func TestLargeMessage(t *testing.T) {
-	rand.Seed(time.Now().Unix())
-
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})
@@ -208,7 +206,6 @@ func TestMaxPendingChunkMessages(t *testing.T) {
 }
 
 func TestExpireIncompleteChunks(t *testing.T) {
-	rand.Seed(time.Now().Unix())
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})
@@ -240,8 +237,6 @@ func TestExpireIncompleteChunks(t *testing.T) {
 }
 
 func TestChunksEnqueueFailed(t *testing.T) {
-	rand.Seed(time.Now().Unix())
-
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})
@@ -278,8 +273,6 @@ func TestChunksEnqueueFailed(t *testing.T) {
 }
 
 func TestSeekChunkMessages(t *testing.T) {
-	rand.Seed(time.Now().Unix())
-
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})
@@ -343,8 +336,6 @@ func TestSeekChunkMessages(t *testing.T) {
 }
 
 func TestChunkAckAndNAck(t *testing.T) {
-	rand.Seed(time.Now().Unix())
-
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})
@@ -400,8 +391,6 @@ func TestChunkAckAndNAck(t *testing.T) {
 }
 
 func TestChunkSize(t *testing.T) {
-	rand.Seed(time.Now().Unix())
-
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,
 	})

pulsar/producer_partition.go

@@ -1394,7 +1394,8 @@ func (p *partitionProducer) ReceivedSendReceipt(response *pb.CommandSendReceipt)
 		)
 
 		if sr.totalChunks > 1 {
-			if sr.chunkID == 0 {
+			switch sr.chunkID {
+			case 0:
 				sr.chunkRecorder.setFirstChunkID(
 					&messageID{
 						int64(response.MessageId.GetLedgerId()),
@@ -1403,7 +1404,7 @@ func (p *partitionProducer) ReceivedSendReceipt(response *pb.CommandSendReceipt)
 						p.partitionIdx,
 						0,
 					})
-			} else if sr.chunkID == sr.totalChunks-1 {
+			case sr.totalChunks - 1:
 				sr.chunkRecorder.setLastChunkID(
 					&messageID{
 						int64(response.MessageId.GetLedgerId()),

pulsar/producer_test.go

@@ -1977,8 +1977,8 @@ func TestWaitForExclusiveProducer(t *testing.T) {
 			Topic:              topicName,
 			ProducerAccessMode: ProducerAccessModeWaitForExclusive,
 		})
-		defer producer2.Close()
 		assert.NoError(t, err)
+		defer producer2.Close()
 		assert.NotNil(t, producer2)
 
 		id, err := producer2.Send(context.Background(), &ProducerMessage{