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/17 07:36:52 UTC
[pulsar] branch master updated: Issue #3373:
RemotelyClosedException when running SampleProducer
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 757c3f9 Issue #3373: RemotelyClosedException when running SampleProducer
757c3f9 is described below
commit 757c3f925ce5c216a733d3a7150e844a320c1e2b
Author: wpl <12...@qq.com>
AuthorDate: Thu Jan 17 15:36:47 2019 +0800
Issue #3373: RemotelyClosedException when running SampleProducer
*Motivation*
Fixes #3373
The service url in SampleProducer is wrong.
*Modification*
Fix the service url in SampleProducer and SampleConsumer.
---
.../src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java | 2 +-
.../src/test/java/org/apache/pulsar/client/tutorial/SampleProducer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java b/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java
index 0b3ffdf..93ee4d2 100644
--- a/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java
+++ b/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleConsumer.java
@@ -26,7 +26,7 @@ import org.apache.pulsar.client.api.PulsarClientException;
public class SampleConsumer {
public static void main(String[] args) throws PulsarClientException, InterruptedException {
- PulsarClient pulsarClient = PulsarClient.builder().serviceUrl("http://localhost:8080").build();
+ PulsarClient pulsarClient = PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build();
Consumer<byte[]> consumer = pulsarClient.newConsumer() //
.topic("persistent://my-tenant/my-ns/my-topic") //
diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleProducer.java b/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleProducer.java
index 467d34c..28997bd 100644
--- a/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleProducer.java
+++ b/pulsar-client/src/test/java/org/apache/pulsar/client/tutorial/SampleProducer.java
@@ -26,7 +26,7 @@ import org.apache.pulsar.client.api.PulsarClientException;
public class SampleProducer {
public static void main(String[] args) throws PulsarClientException, InterruptedException, IOException {
- PulsarClient client = PulsarClient.builder().serviceUrl("http://localhost:6650").build();
+ PulsarClient client = PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build();
Producer<byte[]> producer = client.newProducer().topic("persistent://my-tenant/my-ns/my-topic").create();