Use CE connection args available, instead of hardcoded values (knativ…

…e-extensions#440) (#165)
openshift-knative · Apr 22, 2021 · a561719 · a561719
1 parent 7313634
commit a561719
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/pkg/channel/consolidated/dispatcher/dispatcher.go b/pkg/channel/consolidated/dispatcher/dispatcher.go
@@ -150,11 +150,8 @@ func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispat
 		return nil, fmt.Errorf("unable to create kafka producer against Kafka bootstrap servers %v : %v", args.Brokers, err)
 	}
 
-	// Configured with the same connection arguments of IMC
-	kncloudevents.ConfigureConnectionArgs(&kncloudevents.ConnectionArgs{
-		MaxIdleConns:        1000,
-		MaxIdleConnsPerHost: 100,
-	})
+	// Configure connection arguments
+	kncloudevents.ConfigureConnectionArgs(args.KnCEConnectionArgs)
 
 	dispatcher := &KafkaDispatcher{
 		dispatcher:           eventingchannels.NewMessageDispatcher(logging.FromContext(ctx).Desugar()),