Fix knative-extensions#342

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
slinkydeveloper · Feb 2, 2021 · 7559972 · 7559972
1 parent d4ca4e4
commit 7559972
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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),