Fix #342 (#353)

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
knative-extensions · Feb 2, 2021 · ffd2397 · ffd2397
1 parent 0947a72
commit ffd2397
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),