Merge pull request Azure#419 from spelluru/master

I had to fix this statement to get rid of a compilation error. Please review.
zhengliang19 · Aug 30, 2018 · 9ef326f · 9ef326f
2 parents e00c9bf + 403ebb1
commit 9ef326f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/samples/kafka/quickstart/consumer/src/main/resources/consumer.config b/samples/kafka/quickstart/consumer/src/main/resources/consumer.config
@@ -1,4 +1,4 @@
-bootstrap.servers={YOUR.EVENTHUBS.FQDN}:9093
+bootstrap.servers={EVENT HUB NAMESPACE}.servicebus.windows.net:9093
 group.id=$Default
 request.timeout.ms=60000
 security.protocol=SASL_SSL

diff --git a/samples/kafka/quickstart/producer/src/main/java/com/example/app/TestDataReporter.java b/samples/kafka/quickstart/producer/src/main/java/com/example/app/TestDataReporter.java
@@ -32,6 +32,6 @@ public void onCompletion(RecordMetadata metadata, Exception exception) {
                 }
             });
         }
-        System.out.println("Finished sending " + NUM_MESSAGES + " messages from thread #" + Thread.currentThread.getId() + "!");
+        System.out.println("Finished sending " + NUM_MESSAGES + " messages from thread #" + Thread.currentThread().getId() + "!");
     }
-}
+}
diff --git a/samples/kafka/quickstart/producer/src/main/resources/producer.config b/samples/kafka/quickstart/producer/src/main/resources/producer.config
@@ -1,4 +1,4 @@
-bootstrap.servers={YOUR.EVENTHUBS.FQDN}:9093
+bootstrap.servers={EVENT HUB NAMESPACE}.servicebus.windows.net:9093
 security.protocol=SASL_SSL
 sasl.mechanism=PLAIN
-sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
+sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";