Fix knative-extensions#342 (knative-extensions#355)

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
slinkydeveloper · Feb 2, 2021 · 6c0e33a · 6c0e33a
1 parent 60fe9e4
commit 6c0e33a
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
@@ -105,6 +105,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),