You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/10/20 02:19:21 UTC
[pulsar] branch master updated: [Issue 8294][docs]Some errors on
the official website document of Pulsar Java client #8294 (#8296)
This is an automated email from the ASF dual-hosted git repository.
rxl 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 5f22bae [Issue 8294][docs]Some errors on the official website document of Pulsar Java client #8294 (#8296)
5f22bae is described below
commit 5f22baeb28251f92205a18fe2f2b66fda3bb72f2
Author: yixin <yi...@qq.com>
AuthorDate: Tue Oct 20 10:15:13 2020 +0800
[Issue 8294][docs]Some errors on the official website document of Pulsar Java client #8294 (#8296)
* Some errors on the official website document of Pulsar Java client #8294
Co-authored-by: yixin <yi...@cmss.chinamobile.com>
---
site2/docs/client-libraries-java.md | 8 ++++----
.../versioned_docs/version-2.5.0/client-libraries-java.md | 8 ++++----
.../versioned_docs/version-2.5.1/client-libraries-java.md | 8 ++++----
.../versioned_docs/version-2.5.2/client-libraries-java.md | 8 ++++----
.../versioned_docs/version-2.6.0/client-libraries-java.md | 8 ++++----
.../versioned_docs/version-2.6.1/client-libraries-java.md | 9 ++++-----
.../versioned_docs/version-2.6.2/client-libraries-java.md | 9 ++++-----
7 files changed, 28 insertions(+), 30 deletions(-)
diff --git a/site2/docs/client-libraries-java.md b/site2/docs/client-libraries-java.md
index 2c58691..61ffe82 100644
--- a/site2/docs/client-libraries-java.md
+++ b/site2/docs/client-libraries-java.md
@@ -329,7 +329,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -421,7 +421,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -438,8 +438,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
diff --git a/site2/website/versioned_docs/version-2.5.0/client-libraries-java.md b/site2/website/versioned_docs/version-2.5.0/client-libraries-java.md
index 8846edc..891742cf 100644
--- a/site2/website/versioned_docs/version-2.5.0/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.5.0/client-libraries-java.md
@@ -328,7 +328,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -405,7 +405,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -422,8 +422,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
diff --git a/site2/website/versioned_docs/version-2.5.1/client-libraries-java.md b/site2/website/versioned_docs/version-2.5.1/client-libraries-java.md
index 40e1a99..ec104fd 100644
--- a/site2/website/versioned_docs/version-2.5.1/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.5.1/client-libraries-java.md
@@ -330,7 +330,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -407,7 +407,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -424,8 +424,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
diff --git a/site2/website/versioned_docs/version-2.5.2/client-libraries-java.md b/site2/website/versioned_docs/version-2.5.2/client-libraries-java.md
index 6366e5e..7e60542 100644
--- a/site2/website/versioned_docs/version-2.5.2/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.5.2/client-libraries-java.md
@@ -330,7 +330,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -407,7 +407,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -424,8 +424,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
diff --git a/site2/website/versioned_docs/version-2.6.0/client-libraries-java.md b/site2/website/versioned_docs/version-2.6.0/client-libraries-java.md
index aefb6bf..ba72256 100644
--- a/site2/website/versioned_docs/version-2.6.0/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.6.0/client-libraries-java.md
@@ -330,7 +330,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -422,7 +422,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -439,8 +439,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
diff --git a/site2/website/versioned_docs/version-2.6.1/client-libraries-java.md b/site2/website/versioned_docs/version-2.6.1/client-libraries-java.md
index 8283b2b..8d96dad 100644
--- a/site2/website/versioned_docs/version-2.6.1/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.6.1/client-libraries-java.md
@@ -330,7 +330,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -407,7 +407,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -424,8 +424,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
@@ -636,7 +636,6 @@ With the [reader interface](concepts-clients.md#reader-interface), Pulsar client
The following is an example.
```java
-ReaderConfiguration conf = new ReaderConfiguration();
byte[] msgIdBytes = // Some message ID byte array
MessageId id = MessageId.fromByteArray(msgIdBytes);
Reader reader = pulsarClient.newReader()
diff --git a/site2/website/versioned_docs/version-2.6.2/client-libraries-java.md b/site2/website/versioned_docs/version-2.6.2/client-libraries-java.md
index 32a64da..e78957a 100644
--- a/site2/website/versioned_docs/version-2.6.2/client-libraries-java.md
+++ b/site2/website/versioned_docs/version-2.6.2/client-libraries-java.md
@@ -330,7 +330,7 @@ The following is an example.
```java
Messages messages = consumer.batchReceive();
-for (message in messages) {
+for (Object message : messages) {
// do something
}
consumer.acknowledge(messages)
@@ -407,7 +407,7 @@ Consumer multiTopicConsumer = consumerBuilder
// Alternatively:
Consumer multiTopicConsumer = consumerBuilder
- .topics(
+ .topic(
"topic-1",
"topic-2",
"topic-3"
@@ -424,8 +424,8 @@ consumerBuilder
.subscribeAsync()
.thenAccept(this::receiveMessageFromConsumer);
-private void receiveMessageFromConsumer(Consumer consumer) {
- consumer.receiveAsync().thenAccept(message -> {
+private void receiveMessageFromConsumer(Object consumer) {
+ ((Consumer)consumer).receiveAsync().thenAccept(message -> {
// Do something with the received message
receiveMessageFromConsumer(consumer);
});
@@ -636,7 +636,6 @@ With the [reader interface](concepts-clients.md#reader-interface), Pulsar client
The following is an example.
```java
-ReaderConfiguration conf = new ReaderConfiguration();
byte[] msgIdBytes = // Some message ID byte array
MessageId id = MessageId.fromByteArray(msgIdBytes);
Reader reader = pulsarClient.newReader()