From 7559972010d2b86fcb42eef2384c08c235c673e8 Mon Sep 17 00:00:00 2001 From: slinkydeveloper Date: Tue, 2 Feb 2021 10:15:20 +0100 Subject: [PATCH] Fix #342 Signed-off-by: Francesco Guardiani --- pkg/channel/consolidated/dispatcher/dispatcher.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/channel/consolidated/dispatcher/dispatcher.go b/pkg/channel/consolidated/dispatcher/dispatcher.go index 7298c35292..6256254ca3 100644 --- a/pkg/channel/consolidated/dispatcher/dispatcher.go +++ b/pkg/channel/consolidated/dispatcher/dispatcher.go @@ -104,6 +104,12 @@ 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, + }) + dispatcher := &KafkaDispatcher{ dispatcher: eventingchannels.NewMessageDispatcher(args.Logger.Desugar()), kafkaConsumerFactory: consumer.NewConsumerGroupFactory(args.Brokers, conf),