diff --git a/pkg/source/pubsub/pubsub_source.go b/pkg/source/pubsub/pubsub_source.go index 3d0c8597..4d6cb98c 100644 --- a/pkg/source/pubsub/pubsub_source.go +++ b/pkg/source/pubsub/pubsub_source.go @@ -135,7 +135,7 @@ func newPubSubSource(concurrentWrites int, projectID string, subscriptionID stri return nil, errors.Wrap(err, "Failed to create PubSub client") } - // This temproary logic allows us to fix the bug without a breaking release. + // This temproary logic allows us to fix suboptimal behaviour without a breaking release. // The order of priority is streaming_pull_goroutines > concurrent_writes > previous default // We don't change the default becuase this would cause a major behaviour change in a non-major version bump