File tree Expand file tree Collapse file tree 3 files changed +8
-7
lines changed
Expand file tree Collapse file tree 3 files changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -62,7 +62,7 @@ public static void createTopicWithAzureEventHubsIngestionExample(
6262 String subscriptionId ,
6363 String gcpServiceAccount )
6464 throws IOException {
65- try (TopicAdminClient topicAdminClient = TopicAdminClient .create (TopicAdminSettings . newBuilder (). setEndpoint ( "staging-pubsub.sandbox.googleapis.com:443" ). build () )) {
65+ try (TopicAdminClient topicAdminClient = TopicAdminClient .create ()) {
6666 TopicName topicName = TopicName .of (projectId , topicId );
6767
6868 IngestionDataSourceSettings .AzureEventHubs azureEventHubs =
@@ -85,8 +85,8 @@ public static void createTopicWithAzureEventHubsIngestionExample(
8585 .setIngestionDataSourceSettings (ingestionDataSourceSettings )
8686 .build ());
8787
88- System .out .println ("Created topic with Azure Event Hubs ingestion settings: " +
89- topic .getAllFields ());
88+ System .out .println (
89+ "Created topic with Azure Event Hubs ingestion settings: " + topic .getAllFields ());
9090 }
9191 }
9292}
Original file line number Diff line number Diff line change @@ -77,8 +77,8 @@ public static void createTopicWithConfluentCloudIngestionExample(
7777 .setIngestionDataSourceSettings (ingestionDataSourceSettings )
7878 .build ());
7979
80- System .out .println ("Created topic with Confluent Cloud ingestion settings: " +
81- topic .getAllFields ());
80+ System .out .println (
81+ "Created topic with Confluent Cloud ingestion settings: " + topic .getAllFields ());
8282 }
8383 }
8484}
Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public class AdminIT {
9898 String bootstrapServer = "fake-bootstrap-server-id.us-south1.gcp.confluent.cloud:9092" ;
9999 String clusterId = "fake-cluster-id" ;
100100 String confluentTopic = "fake-confluent-topic-name" ;
101- String identityPoolId = "fake-pool-id"
101+ String identityPoolId = "fake-pool-id" ;
102102 // Azure Event Hubs ingestion settings.
103103 String resourceGroup = "fake-resource-group" ;
104104 String namespace = "fake-namespace" ;
@@ -447,7 +447,8 @@ public void testAdmin() throws Exception {
447447 tenantId ,
448448 subscriptionId ,
449449 gcpServiceAccount );
450- assertThat (bout .toString ()).contains ("google.pubsub.v1.Topic.name=" + azureEventHubsIngestionTopicName .toString ());
450+ assertThat (bout .toString ()).contains (
451+ "google.pubsub.v1.Topic.name=" + azureEventHubsIngestionTopicName .toString ());
451452 assertThat (bout .toString ()).contains (resourceGroup );
452453 assertThat (bout .toString ()).contains (namespace );
453454 assertThat (bout .toString ()).contains (eventHub );
You can’t perform that action at this time.
0 commit comments