This is an automated email from the ASF dual-hosted git repository.
liuyu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new c502b839cb8 Refine the java client doc (#516)
c502b839cb8 is described below
commit c502b839cb8d1db4ade2b483adb95b8663f9166b
Author: Zike Yang <z...@apache.org>
AuthorDate: Fri Apr 14 17:50:41 2023 +0800
Refine the java client doc (#516)
---
docs/client-libraries-java-use.md | 4 ++--
static/reference/2.10.x/client/client-libraries-java.md | 2 +-
static/reference/2.6.x/client/client-libraries-java.md | 2 +-
static/reference/2.7.x/client/client-libraries-java.md | 2 +-
static/reference/2.8.x/client/client-libraries-java.md | 2 +-
static/reference/2.9.x/client/client-libraries-java.md | 2 +-
versioned_docs/version-2.10.x/client-libraries-java.md | 4 ++--
versioned_docs/version-2.11.x/client-libraries-java.md | 4 ++--
versioned_docs/version-2.2.0/client-libraries-java.md | 4 ++--
versioned_docs/version-2.2.1/client-libraries-java.md | 2 +-
versioned_docs/version-2.3.0/client-libraries-java.md | 4 ++--
versioned_docs/version-2.3.1/client-libraries-java.md | 2 +-
versioned_docs/version-2.3.2/client-libraries-java.md | 4 ++--
versioned_docs/version-2.4.0/client-libraries-java.md | 2 +-
versioned_docs/version-2.4.1/client-libraries-java.md | 2 +-
versioned_docs/version-2.4.2/client-libraries-java.md | 2 +-
versioned_docs/version-2.5.0/client-libraries-java.md | 2 +-
versioned_docs/version-2.5.1/client-libraries-java.md | 2 +-
versioned_docs/version-2.5.2/client-libraries-java.md | 2 +-
versioned_docs/version-2.6.0/client-libraries-java.md | 2 +-
versioned_docs/version-2.6.1/client-libraries-java.md | 2 +-
versioned_docs/version-2.6.2/client-libraries-java.md | 2 +-
versioned_docs/version-2.6.3/client-libraries-java.md | 2 +-
versioned_docs/version-2.6.4/client-libraries-java.md | 2 +-
versioned_docs/version-2.7.0/client-libraries-java.md | 4 ++--
versioned_docs/version-2.7.1/client-libraries-java.md | 4 ++--
versioned_docs/version-2.7.2/client-libraries-java.md | 4 ++--
versioned_docs/version-2.7.3/client-libraries-java.md | 4 ++--
versioned_docs/version-2.7.4/client-libraries-java.md | 4 ++--
versioned_docs/version-2.7.5/client-libraries-java.md | 4 ++--
versioned_docs/version-2.8.x/client-libraries-java.md | 4 ++--
versioned_docs/version-2.9.x/client-libraries-java.md | 4 ++--
32 files changed, 46 insertions(+), 46 deletions(-)
diff --git a/docs/client-libraries-java-use.md
b/docs/client-libraries-java-use.md
index 68543ada706..f4827d02994 100644
--- a/docs/client-libraries-java-use.md
+++ b/docs/client-libraries-java-use.md
@@ -70,7 +70,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -79,7 +79,7 @@ while (true) {
}
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder. The `MessageListener` will use a thread pool
inside the PulsarClient. You can set the number of threads to use for message
listeners in the ClientBuilder.
```java
MessageListener myMessageListener = (consumer, msg) -> {
diff --git a/static/reference/2.10.x/client/client-libraries-java.md
b/static/reference/2.10.x/client/client-libraries-java.md
index 4da544929d0..3f6ddeddb7c 100644
--- a/static/reference/2.10.x/client/client-libraries-java.md
+++ b/static/reference/2.10.x/client/client-libraries-java.md
@@ -324,7 +324,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/static/reference/2.6.x/client/client-libraries-java.md
b/static/reference/2.6.x/client/client-libraries-java.md
index 08d62c760d5..d332c7f0584 100644
--- a/static/reference/2.6.x/client/client-libraries-java.md
+++ b/static/reference/2.6.x/client/client-libraries-java.md
@@ -280,7 +280,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/static/reference/2.7.x/client/client-libraries-java.md
b/static/reference/2.7.x/client/client-libraries-java.md
index f56e726bc69..3fffbaa2319 100644
--- a/static/reference/2.7.x/client/client-libraries-java.md
+++ b/static/reference/2.7.x/client/client-libraries-java.md
@@ -281,7 +281,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/static/reference/2.8.x/client/client-libraries-java.md
b/static/reference/2.8.x/client/client-libraries-java.md
index b861b31ee0a..c6bc85b897a 100644
--- a/static/reference/2.8.x/client/client-libraries-java.md
+++ b/static/reference/2.8.x/client/client-libraries-java.md
@@ -279,7 +279,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/static/reference/2.9.x/client/client-libraries-java.md
b/static/reference/2.9.x/client/client-libraries-java.md
index e5b156ceaed..74fc6541ad1 100644
--- a/static/reference/2.9.x/client/client-libraries-java.md
+++ b/static/reference/2.9.x/client/client-libraries-java.md
@@ -283,7 +283,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.10.x/client-libraries-java.md
b/versioned_docs/version-2.10.x/client-libraries-java.md
index 12230feb12d..f1da3c4e833 100644
--- a/versioned_docs/version-2.10.x/client-libraries-java.md
+++ b/versioned_docs/version-2.10.x/client-libraries-java.md
@@ -724,7 +724,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -734,7 +734,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.11.x/client-libraries-java.md
b/versioned_docs/version-2.11.x/client-libraries-java.md
index dfbd64180c4..ea912920fde 100644
--- a/versioned_docs/version-2.11.x/client-libraries-java.md
+++ b/versioned_docs/version-2.11.x/client-libraries-java.md
@@ -438,7 +438,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -447,7 +447,7 @@ while (true) {
}
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
MessageListener myMessageListener = (consumer, msg) -> {
diff --git a/versioned_docs/version-2.2.0/client-libraries-java.md
b/versioned_docs/version-2.2.0/client-libraries-java.md
index d51d173e2ff..6a37c8e7628 100644
--- a/versioned_docs/version-2.2.0/client-libraries-java.md
+++ b/versioned_docs/version-2.2.0/client-libraries-java.md
@@ -657,7 +657,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -667,7 +667,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.2.1/client-libraries-java.md
b/versioned_docs/version-2.2.1/client-libraries-java.md
index 99885bafc0f..25c83ca90f8 100644
--- a/versioned_docs/version-2.2.1/client-libraries-java.md
+++ b/versioned_docs/version-2.2.1/client-libraries-java.md
@@ -231,7 +231,7 @@ do {
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} while (true);
diff --git a/versioned_docs/version-2.3.0/client-libraries-java.md
b/versioned_docs/version-2.3.0/client-libraries-java.md
index d51d173e2ff..6a37c8e7628 100644
--- a/versioned_docs/version-2.3.0/client-libraries-java.md
+++ b/versioned_docs/version-2.3.0/client-libraries-java.md
@@ -657,7 +657,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -667,7 +667,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.3.1/client-libraries-java.md
b/versioned_docs/version-2.3.1/client-libraries-java.md
index 1fc7bb5f30f..ae3ed2023e2 100644
--- a/versioned_docs/version-2.3.1/client-libraries-java.md
+++ b/versioned_docs/version-2.3.1/client-libraries-java.md
@@ -234,7 +234,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.3.2/client-libraries-java.md
b/versioned_docs/version-2.3.2/client-libraries-java.md
index 6a13e56685e..9b6ac8bc4b0 100644
--- a/versioned_docs/version-2.3.2/client-libraries-java.md
+++ b/versioned_docs/version-2.3.2/client-libraries-java.md
@@ -657,7 +657,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -667,7 +667,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.4.0/client-libraries-java.md
b/versioned_docs/version-2.4.0/client-libraries-java.md
index 3b5db29de6b..6167a39e34d 100644
--- a/versioned_docs/version-2.4.0/client-libraries-java.md
+++ b/versioned_docs/version-2.4.0/client-libraries-java.md
@@ -252,7 +252,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.4.1/client-libraries-java.md
b/versioned_docs/version-2.4.1/client-libraries-java.md
index 6bf02ff5318..7ff60d37265 100644
--- a/versioned_docs/version-2.4.1/client-libraries-java.md
+++ b/versioned_docs/version-2.4.1/client-libraries-java.md
@@ -278,7 +278,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.4.2/client-libraries-java.md
b/versioned_docs/version-2.4.2/client-libraries-java.md
index 6bf02ff5318..7ff60d37265 100644
--- a/versioned_docs/version-2.4.2/client-libraries-java.md
+++ b/versioned_docs/version-2.4.2/client-libraries-java.md
@@ -278,7 +278,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.5.0/client-libraries-java.md
b/versioned_docs/version-2.5.0/client-libraries-java.md
index 150642f6404..70eecfbee73 100644
--- a/versioned_docs/version-2.5.0/client-libraries-java.md
+++ b/versioned_docs/version-2.5.0/client-libraries-java.md
@@ -296,7 +296,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.5.1/client-libraries-java.md
b/versioned_docs/version-2.5.1/client-libraries-java.md
index 151be98b712..92c2769651a 100644
--- a/versioned_docs/version-2.5.1/client-libraries-java.md
+++ b/versioned_docs/version-2.5.1/client-libraries-java.md
@@ -298,7 +298,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.5.2/client-libraries-java.md
b/versioned_docs/version-2.5.2/client-libraries-java.md
index 151be98b712..92c2769651a 100644
--- a/versioned_docs/version-2.5.2/client-libraries-java.md
+++ b/versioned_docs/version-2.5.2/client-libraries-java.md
@@ -298,7 +298,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.6.0/client-libraries-java.md
b/versioned_docs/version-2.6.0/client-libraries-java.md
index 82574b7b517..ceee096feed 100644
--- a/versioned_docs/version-2.6.0/client-libraries-java.md
+++ b/versioned_docs/version-2.6.0/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.6.1/client-libraries-java.md
b/versioned_docs/version-2.6.1/client-libraries-java.md
index a86a2202c93..5e7eee39b6a 100644
--- a/versioned_docs/version-2.6.1/client-libraries-java.md
+++ b/versioned_docs/version-2.6.1/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.6.2/client-libraries-java.md
b/versioned_docs/version-2.6.2/client-libraries-java.md
index a86a2202c93..5e7eee39b6a 100644
--- a/versioned_docs/version-2.6.2/client-libraries-java.md
+++ b/versioned_docs/version-2.6.2/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.6.3/client-libraries-java.md
b/versioned_docs/version-2.6.3/client-libraries-java.md
index a86a2202c93..5e7eee39b6a 100644
--- a/versioned_docs/version-2.6.3/client-libraries-java.md
+++ b/versioned_docs/version-2.6.3/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.6.4/client-libraries-java.md
b/versioned_docs/version-2.6.4/client-libraries-java.md
index ae2f4fb0fce..5f5078b296a 100644
--- a/versioned_docs/version-2.6.4/client-libraries-java.md
+++ b/versioned_docs/version-2.6.4/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
diff --git a/versioned_docs/version-2.7.0/client-libraries-java.md
b/versioned_docs/version-2.7.0/client-libraries-java.md
index 65c93b3ce58..f4f9979d1d6 100644
--- a/versioned_docs/version-2.7.0/client-libraries-java.md
+++ b/versioned_docs/version-2.7.0/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.7.1/client-libraries-java.md
b/versioned_docs/version-2.7.1/client-libraries-java.md
index 65c93b3ce58..f4f9979d1d6 100644
--- a/versioned_docs/version-2.7.1/client-libraries-java.md
+++ b/versioned_docs/version-2.7.1/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.7.2/client-libraries-java.md
b/versioned_docs/version-2.7.2/client-libraries-java.md
index 65c93b3ce58..f4f9979d1d6 100644
--- a/versioned_docs/version-2.7.2/client-libraries-java.md
+++ b/versioned_docs/version-2.7.2/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.7.3/client-libraries-java.md
b/versioned_docs/version-2.7.3/client-libraries-java.md
index 65c93b3ce58..f4f9979d1d6 100644
--- a/versioned_docs/version-2.7.3/client-libraries-java.md
+++ b/versioned_docs/version-2.7.3/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.7.4/client-libraries-java.md
b/versioned_docs/version-2.7.4/client-libraries-java.md
index b0c9d0cd2f2..e4438f77924 100644
--- a/versioned_docs/version-2.7.4/client-libraries-java.md
+++ b/versioned_docs/version-2.7.4/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.7.5/client-libraries-java.md
b/versioned_docs/version-2.7.5/client-libraries-java.md
index b60fd3a1e7e..51a0c07ed89 100644
--- a/versioned_docs/version-2.7.5/client-libraries-java.md
+++ b/versioned_docs/version-2.7.5/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.printf("Message received: %s", new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.8.x/client-libraries-java.md
b/versioned_docs/version-2.8.x/client-libraries-java.md
index bbfaf13334a..5f885261f21 100644
--- a/versioned_docs/version-2.8.x/client-libraries-java.md
+++ b/versioned_docs/version-2.8.x/client-libraries-java.md
@@ -299,7 +299,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -309,7 +309,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
diff --git a/versioned_docs/version-2.9.x/client-libraries-java.md
b/versioned_docs/version-2.9.x/client-libraries-java.md
index 12d9bc30b84..755a5f8dc66 100644
--- a/versioned_docs/version-2.9.x/client-libraries-java.md
+++ b/versioned_docs/version-2.9.x/client-libraries-java.md
@@ -343,7 +343,7 @@ while (true) {
// Do something with the message
System.out.println("Message received: " + new String(msg.getData()));
- // Acknowledge the message so that it can be deleted by the message
broker
+ // Acknowledge the message
consumer.acknowledge(msg);
} catch (Exception e) {
// Message failed to process, redeliver later
@@ -353,7 +353,7 @@ while (true) {
```
-If you don't want to block your main thread and rather listen constantly for
new messages, consider using a `MessageListener`.
+If you don't want to block your main thread but constantly listen for new
messages, consider using a `MessageListener`. The `MessageListener` uses a
thread pool inside the client. You can set the number of threads for message
listeners in the ClientBuilder.
```java
