search

GoogleCloudPlatform / DataflowJavaSDK

Google Cloud Dataflow provides a simple, powerful model for building both batch and streaming parallel data processing pipelines.
http://cloud.google.com/dataflow
855 stars 324 forks source link

Override default `ACK_TIMEOUT_SEC` when creating random subs for PubsubIO #532

Open jung-kim opened 7 years ago

jung-kim commented 7 years ago

When creating random subscription for PubsubIO, code uses hardcoded constant value and there is no way to override this value.

subscriptionPath = pubsubClient.createRandomSubscription(projectPath, topicPath, ACK_TIMEOUT_SEC);

It would be nice to configurable option to override this value.