chore: build problem and integration cronsumer dep upgrade

Author: Abdulsametileri

consumer_config.go

@@ -122,25 +122,24 @@ func (cfg *ConsumerConfig) newCronsumerConfig() *kcronsumer.Config {
 		ClientID:     cfg.RetryConfiguration.ClientID,
 		Brokers:      cfg.RetryConfiguration.Brokers,
 		Consumer: kcronsumer.ConsumerConfig{
-			ClientID:             cfg.ClientID,
-			GroupID:              cfg.Reader.GroupID,
-			Topic:                cfg.RetryConfiguration.Topic,
-			DeadLetterTopic:      cfg.RetryConfiguration.DeadLetterTopic,
-			Cron:                 cfg.RetryConfiguration.StartTimeCron,
-			Duration:             cfg.RetryConfiguration.WorkDuration,
-			MaxRetry:             cfg.RetryConfiguration.MaxRetry,
-			VerifyTopicOnStartup: true,
-			Concurrency:          cfg.RetryConfiguration.Concurrency,
-			QueueCapacity:        cfg.RetryConfiguration.QueueCapacity,
-			MinBytes:             cfg.Reader.MinBytes,
-			MaxBytes:             cfg.Reader.MaxBytes,
-			MaxWait:              cfg.Reader.MaxWait,
-			CommitInterval:       cfg.Reader.CommitInterval,
-			HeartbeatInterval:    cfg.Reader.HeartbeatInterval,
-			SessionTimeout:       cfg.Reader.SessionTimeout,
-			RebalanceTimeout:     cfg.Reader.RebalanceTimeout,
-			StartOffset:          kcronsumer.ToStringOffset(cfg.Reader.StartOffset),
-			RetentionTime:        cfg.Reader.RetentionTime,
+			ClientID:          cfg.ClientID,
+			GroupID:           cfg.Reader.GroupID,
+			Topic:             cfg.RetryConfiguration.Topic,
+			DeadLetterTopic:   cfg.RetryConfiguration.DeadLetterTopic,
+			Cron:              cfg.RetryConfiguration.StartTimeCron,
+			Duration:          cfg.RetryConfiguration.WorkDuration,
+			MaxRetry:          cfg.RetryConfiguration.MaxRetry,
+			Concurrency:       cfg.RetryConfiguration.Concurrency,
+			QueueCapacity:     cfg.RetryConfiguration.QueueCapacity,
+			MinBytes:          cfg.Reader.MinBytes,
+			MaxBytes:          cfg.Reader.MaxBytes,
+			MaxWait:           cfg.Reader.MaxWait,
+			CommitInterval:    cfg.Reader.CommitInterval,
+			HeartbeatInterval: cfg.Reader.HeartbeatInterval,
+			SessionTimeout:    cfg.Reader.SessionTimeout,
+			RebalanceTimeout:  cfg.Reader.RebalanceTimeout,
+			StartOffset:       kcronsumer.ToStringOffset(cfg.Reader.StartOffset),
+			RetentionTime:     cfg.Reader.RetentionTime,
 		},
 		Producer: kcronsumer.ProducerConfig{
 			Balancer:     cfg.RetryConfiguration.Balancer,

test/integration/go.mod

@@ -10,7 +10,7 @@ require (
 )
 
 require (
-	github.com/Trendyol/kafka-cronsumer v1.5.5 // indirect
+	github.com/Trendyol/kafka-cronsumer v1.5.6 // indirect
 	github.com/Trendyol/otel-kafka-konsumer v0.0.7 // indirect
 	github.com/andybalholm/brotli v1.0.5 // indirect
 	github.com/ansrivas/fiberprometheus/v2 v2.6.1 // indirect

test/integration/go.sum

@@ -11,6 +11,7 @@ github.com/Trendyol/kafka-cronsumer v1.5.4-0.20240827135347-7ed5187ea81d/go.mod
 github.com/Trendyol/kafka-cronsumer v1.5.4/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU=
 github.com/Trendyol/kafka-cronsumer v1.5.5-0.20241024185446-b44371b7a3ec/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU=
 github.com/Trendyol/kafka-cronsumer v1.5.5/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU=
+github.com/Trendyol/kafka-cronsumer v1.5.6/go.mod h1:yBs+7SMxqHuQPU1fjyjn1sKIulnD5s1oOfeVysN9pso=
 github.com/Trendyol/otel-kafka-konsumer v0.0.7 h1:sT1TE2rgfsdrJWrXKz5j6dPkKJsvP+Tv0Dea4ORqJ+4=
 github.com/Trendyol/otel-kafka-konsumer v0.0.7/go.mod h1:zdCaFclzRCO9fzcjxkHrWOB3I2+uTPrmkq4zczkD1F0=
 github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs=