Merge pull request #17 from kubescape/redelivery

use RedeliveryDelaySeconds as seconds instead of nanoseconds
kubescape · Dec 22, 2023 · ac4666b · ac4666b
2 parents f94fdf3 + 9632e3c
commit ac4666b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/connector/consumer.go b/pulsar/connector/consumer.go
@@ -36,7 +36,7 @@ func (opt *createConsumerOptions) defaults(config config.PulsarConfig) {
 		opt.MaxDeliveryAttempts = uint32(config.MaxDeliveryAttempts)
 	}
 	if opt.RedeliveryDelay == 0 {
-		opt.RedeliveryDelay = time.Duration(config.RedeliveryDelaySeconds)
+		opt.RedeliveryDelay = time.Second * time.Duration(config.RedeliveryDelaySeconds)
 	}
 	if opt.Tenant == "" {
 		opt.Tenant = config.Tenant