You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/01/25 05:52:31 UTC
[pulsar] branch master updated: Use topics in public/default
namespaces for kafka ProducerExample and ConsumerExample (#3401)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 3255957 Use topics in public/default namespaces for kafka ProducerExample and ConsumerExample (#3401)
3255957 is described below
commit 32559577eec1feffe57aeb6c2ca3595920b8c023
Author: wpl <12...@qq.com>
AuthorDate: Fri Jan 25 13:52:26 2019 +0800
Use topics in public/default namespaces for kafka ProducerExample and ConsumerExample (#3401)
Update ProducerExample and ConsumerExample to use topics in public/default namespace.
---
.../org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java | 2 +-
.../org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java
index 9c7bbe6..983d7b7 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ConsumerExample.java
@@ -32,7 +32,7 @@ import org.slf4j.LoggerFactory;
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/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java
index b764406..a95413c 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples/ProducerExample.java
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory;
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");