We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 68f9047 commit af86c42Copy full SHA for af86c42
debezium-server-pubsub/src/main/java/io/debezium/server/pubsub/PubSubChangeConsumer.java
@@ -227,7 +227,8 @@ void connect() {
227
228
if (address.isPresent()) {
229
builder.setChannelProvider(channelProvider).setCredentialsProvider(credentialsProvider);
230
- } else if (region.isPresent()) {
+ }
231
+ else if (region.isPresent()) {
232
String endpoint = String.format("%s-pubsub.googleapis.com:443", region.get());
233
builder.setEndpoint(endpoint);
234
}
0 commit comments