Use topics in public/default namespaces for kafka ProducerExample and…

… ConsumerExample (apache#3401) Update ProducerExample and ConsumerExample to use topics in public/default namespace.
leizhiyuan · Jan 25, 2019 · 3255957 · 3255957
1 parent 14390da
commit 3255957
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...a-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java b/...a-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java
@@ -32,7 +32,7 @@
 public class ConsumerExample {
 
     public static void main(String[] args) {
-        String topic = "persistent://prop/ns-abc/my-topic";
+        String topic = "persistent://public/default/test";
 
         Properties props = new Properties();
         props.put("bootstrap.servers", "pulsar://localhost:6650");

diff --git a/...a-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java b/...a-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java
@@ -30,7 +30,7 @@
 
 public class ProducerExample {
     public static void main(String[] args) {
-        String topic = "persistent://prop/ns-abc/my-topic";
+        String topic = "persistent://public/default/test";
 
         Properties props = new Properties();
         props.put("bootstrap.servers", "pulsar://localhost:6650");