From a56171932a5308486e50a651642caa3802e01a69 Mon Sep 17 00:00:00 2001 From: Ali Ok Date: Thu, 22 Apr 2021 07:40:31 +0300 Subject: [PATCH] Use CE connection args available, instead of hardcoded values (https://github.com/knative-sandbox/eventing-kafka/pull/440) (#165) --- pkg/channel/consolidated/dispatcher/dispatcher.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/pkg/channel/consolidated/dispatcher/dispatcher.go b/pkg/channel/consolidated/dispatcher/dispatcher.go index a4b94e8aad..25d33c6f38 100644 --- 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()),