feat: add prealloc linter

.golangci.yml

@@ -30,6 +30,7 @@ linters:
     - unparam
     - unused
     - whitespace
+    - prealloc
 
 service:
   golangci-lint-version: 1.55.2 # use the fixed version to not introduce new linters unexpectedly

connector.go

@@ -180,8 +180,7 @@ func newConfig(cf any) (*config.Connector, error) {
 func createKafkaClient(cc *config.Connector) (kafka.Client, error) {
 	kafkaClient := kafka.NewClient(cc)
 
-	var topics []string
-
+	topics := make([]string, 0, len(cc.Kafka.CollectionTopicMapping))
 	for _, topic := range cc.Kafka.CollectionTopicMapping {
 		topics = append(topics, topic)
 	}

kafka/client.go

@@ -79,8 +79,7 @@ func newTLSContent(
 }
 
 func (c *client) GetEndOffsets(topic string, partitions []int) ([]kafka.PartitionOffsets, error) {
-	var offsetRequests []kafka.OffsetRequest
-
+	offsetRequests := make([]kafka.OffsetRequest, 0, len(partitions))
 	for _, partition := range partitions {
 		offsetRequests = append(offsetRequests, kafka.LastOffsetOf(partition))
 	}

kafka/metadata/kafka_metadata.go

@@ -24,8 +24,7 @@ type kafkaMetadata struct {
 }
 
 func (s *kafkaMetadata) Save(state map[uint16]*models.CheckpointDocument, dirtyOffsets map[uint16]bool, _ string) error {
-	var messages []kafka.Message
-
+	messages := make([]kafka.Message, 0, len(state))
 	for vbID, document := range state {
 		if !dirtyOffsets[vbID] {
 			continue