You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/12/28 12:26:33 UTC
[pulsar] branch asf-site updated: Updated site at revision a010166
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 5c463a8 Updated site at revision a010166
5c463a8 is described below
commit 5c463a8989a390b0a8bf4e51763d4d171f05b4bc
Author: jenkins <bu...@apache.org>
AuthorDate: Fri Dec 28 12:26:25 2018 +0000
Updated site at revision a010166
---
.../docs/latest/adaptors/PulsarSpark/index.html | 10 +++----
.../docs/latest/adaptors/PulsarStorm/index.html | 8 +++---
content/docs/latest/admin-api/overview/index.html | 18 ++++++------
content/docs/latest/clients/Cpp/index.html | 8 +++---
content/docs/latest/clients/Java/index.html | 16 +++++------
content/docs/latest/clients/Python/index.html | 10 +++----
content/docs/latest/clients/WebSocket/index.html | 8 +++---
content/docs/latest/clients/go/index.html | 6 ++--
.../docs/latest/cookbooks/Encryption/index.html | 6 ++--
.../latest/cookbooks/PartitionedTopics/index.html | 16 +++++------
.../latest/cookbooks/RetentionExpiry/index.html | 16 +++++------
.../docs/latest/cookbooks/compaction/index.html | 8 +++---
.../cookbooks/message-deduplication/index.html | 12 ++++----
.../docs/latest/cookbooks/message-queue/index.html | 16 +++++------
.../latest/cookbooks/tiered-storage/index.html | 6 ++--
.../docs/latest/deployment/Kubernetes/index.html | 4 +--
.../docs/latest/deployment/aws-cluster/index.html | 6 ++--
content/docs/latest/deployment/cluster/index.html | 6 ++--
content/docs/latest/deployment/instance/index.html | 6 ++--
.../ConceptsAndArchitecture/index.html | 4 +--
.../latest/getting-started/LocalCluster/index.html | 4 +--
.../latest/getting-started/Pulsar-2.0/index.html | 2 +-
.../docs/latest/getting-started/docker/index.html | 4 +--
.../docs/latest/project/BinaryProtocol/index.html | 4 +--
content/docs/latest/project/CompileCpp/index.html | 8 +++---
.../docs/latest/project/SimulationTools/index.html | 2 +-
.../docs/latest/project/schema-storage/index.html | 4 +--
content/docs/latest/reference/CliTools/index.html | 22 +++++++--------
.../docs/latest/security/authorization/index.html | 14 +++++-----
content/docs/latest/security/encryption/index.html | 6 ++--
.../zh-CN/2.1.0-incubating/adaptors-storm.html | 26 +++++++++---------
.../2.1.0-incubating/adaptors-storm/index.html | 26 +++++++++---------
.../zh-CN/2.1.1-incubating/adaptors-storm.html | 26 +++++++++---------
.../2.1.1-incubating/adaptors-storm/index.html | 26 +++++++++---------
content/docs/zh-CN/adaptors-storm.html | 26 +++++++++---------
content/docs/zh-CN/adaptors-storm/index.html | 26 +++++++++---------
content/docs/zh-CN/next/adaptors-storm.html | 26 +++++++++---------
content/docs/zh-CN/next/adaptors-storm/index.html | 26 +++++++++---------
content/ja/adaptors/PulsarSpark/index.html | 8 +++---
content/ja/adaptors/PulsarStorm/index.html | 6 ++--
content/ja/admin/AdminInterface/index.html | 12 ++++----
content/ja/admin/Authz/index.html | 12 ++++----
content/ja/admin/ClustersBrokers/index.html | 6 ++--
content/ja/admin/PropertiesNamespaces/index.html | 6 ++--
content/ja/advanced/PartitionedTopics/index.html | 12 ++++----
content/ja/advanced/RetentionExpiry/index.html | 12 ++++----
content/ja/clients/Cpp/index.html | 6 ++--
content/ja/clients/Java/index.html | 8 +++---
content/ja/clients/Python/index.html | 8 +++---
content/ja/clients/WebSocket/index.html | 8 +++---
content/ja/deployment/InstanceSetup/index.html | 6 ++--
content/ja/deployment/Kubernetes/index.html | 4 +--
.../ConceptsAndArchitecture/index.html | 2 +-
content/ja/getting-started/LocalCluster/index.html | 4 +--
content/ja/project/BinaryProtocol/index.html | 4 +--
content/ja/project/SimulationTools/index.html | 2 +-
content/ja/reference/CliTools/index.html | 18 ++++++------
content/swagger/swagger.json | 32 +++++++++++-----------
58 files changed, 322 insertions(+), 322 deletions(-)
diff --git a/content/docs/latest/adaptors/PulsarSpark/index.html b/content/docs/latest/adaptors/PulsarSpark/index.html
index 37d59c5..a30d928 100644
--- a/content/docs/latest/adaptors/PulsarSpark/index.html
+++ b/content/docs/latest/adaptors/PulsarSpark/index.html
@@ -1079,9 +1079,9 @@
- <li><a href="/docs/latest/adaptors/PulsarSpark/">Spark Streaming Pulsar receiver</a></li>
+ <li><a href="/docs/latest/adaptors/PulsarSpark/">Spark Streaming Pulsar receiver</a></li>
@@ -1325,9 +1325,9 @@
- <li><a href="/docs/latest/adaptors/PulsarSpark/">Spark Streaming Pulsar receiver</a></li>
+ <li><a href="/docs/latest/adaptors/PulsarSpark/">Spark Streaming Pulsar receiver</a></li>
@@ -1537,6 +1537,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1615,8 +1617,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1673,9 +1673,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/adaptors/PulsarStorm/index.html b/content/docs/latest/adaptors/PulsarStorm/index.html
index 52000e9..3059cf5 100644
--- a/content/docs/latest/adaptors/PulsarStorm/index.html
+++ b/content/docs/latest/adaptors/PulsarStorm/index.html
@@ -1083,9 +1083,9 @@
- <li><a href="/docs/latest/adaptors/PulsarStorm/">Pulsar adaptor for Apache Storm</a></li>
+ <li><a href="/docs/latest/adaptors/PulsarStorm/">Pulsar adaptor for Apache Storm</a></li>
@@ -1291,6 +1291,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1369,8 +1371,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1427,9 +1427,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/admin-api/overview/index.html b/content/docs/latest/admin-api/overview/index.html
index 810d289..80a6f28 100644
--- a/content/docs/latest/admin-api/overview/index.html
+++ b/content/docs/latest/admin-api/overview/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1271,9 +1271,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1439,9 +1439,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1685,9 +1685,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1805,6 +1805,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1883,8 +1885,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1941,9 +1941,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/clients/Cpp/index.html b/content/docs/latest/clients/Cpp/index.html
index 58e0246..5dabb35 100644
--- a/content/docs/latest/clients/Cpp/index.html
+++ b/content/docs/latest/clients/Cpp/index.html
@@ -1005,9 +1005,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1033,6 +1033,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1155,8 +1157,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
@@ -1287,9 +1287,9 @@
- <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
+ <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
diff --git a/content/docs/latest/clients/Java/index.html b/content/docs/latest/clients/Java/index.html
index 73ca7e0..b938e5f 100644
--- a/content/docs/latest/clients/Java/index.html
+++ b/content/docs/latest/clients/Java/index.html
@@ -1005,9 +1005,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1033,6 +1033,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1155,8 +1157,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
@@ -1301,6 +1301,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1379,8 +1381,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1437,9 +1437,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1557,9 +1557,9 @@
- <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
+ <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1805,9 +1805,9 @@
- <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
+ <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
diff --git a/content/docs/latest/clients/Python/index.html b/content/docs/latest/clients/Python/index.html
index 60bea8e..4d34e49 100644
--- a/content/docs/latest/clients/Python/index.html
+++ b/content/docs/latest/clients/Python/index.html
@@ -1005,9 +1005,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1033,6 +1033,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1155,8 +1157,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
@@ -1343,9 +1343,9 @@
- <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
+ <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
@@ -1365,9 +1365,9 @@
- <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
+ <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
diff --git a/content/docs/latest/clients/WebSocket/index.html b/content/docs/latest/clients/WebSocket/index.html
index b881453..0c3f19d 100644
--- a/content/docs/latest/clients/WebSocket/index.html
+++ b/content/docs/latest/clients/WebSocket/index.html
@@ -1107,9 +1107,9 @@
- <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
+ <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
@@ -1353,9 +1353,9 @@
- <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
+ <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
@@ -1579,9 +1579,9 @@
- <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
+ <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
@@ -1601,9 +1601,9 @@
- <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
+ <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
diff --git a/content/docs/latest/clients/go/index.html b/content/docs/latest/clients/go/index.html
index a06ad5f..1492ffb 100644
--- a/content/docs/latest/clients/go/index.html
+++ b/content/docs/latest/clients/go/index.html
@@ -1005,9 +1005,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1033,6 +1033,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1155,8 +1157,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
diff --git a/content/docs/latest/cookbooks/Encryption/index.html b/content/docs/latest/cookbooks/Encryption/index.html
index a6132a3..18ca402 100644
--- a/content/docs/latest/cookbooks/Encryption/index.html
+++ b/content/docs/latest/cookbooks/Encryption/index.html
@@ -1567,9 +1567,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1823,9 +1823,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1851,9 +1851,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/latest/cookbooks/PartitionedTopics/index.html b/content/docs/latest/cookbooks/PartitionedTopics/index.html
index d717204..c5c0499 100644
--- a/content/docs/latest/cookbooks/PartitionedTopics/index.html
+++ b/content/docs/latest/cookbooks/PartitionedTopics/index.html
@@ -1069,9 +1069,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1315,9 +1315,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1497,6 +1497,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1615,8 +1617,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1681,9 +1681,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1829,9 +1829,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -2085,9 +2085,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -2113,9 +2113,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/latest/cookbooks/RetentionExpiry/index.html b/content/docs/latest/cookbooks/RetentionExpiry/index.html
index a592537..763a81c 100644
--- a/content/docs/latest/cookbooks/RetentionExpiry/index.html
+++ b/content/docs/latest/cookbooks/RetentionExpiry/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1361,9 +1361,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
@@ -1607,9 +1607,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
@@ -1853,9 +1853,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
@@ -2075,9 +2075,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -2103,9 +2103,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/latest/cookbooks/compaction/index.html b/content/docs/latest/cookbooks/compaction/index.html
index 3c75e4d..e0c2266 100644
--- a/content/docs/latest/cookbooks/compaction/index.html
+++ b/content/docs/latest/cookbooks/compaction/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1337,9 +1337,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
diff --git a/content/docs/latest/cookbooks/message-deduplication/index.html b/content/docs/latest/cookbooks/message-deduplication/index.html
index 0a2c71c..7767ce8 100644
--- a/content/docs/latest/cookbooks/message-deduplication/index.html
+++ b/content/docs/latest/cookbooks/message-deduplication/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1287,9 +1287,9 @@
- <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
+ <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
@@ -1585,9 +1585,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1613,9 +1613,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/latest/cookbooks/message-queue/index.html b/content/docs/latest/cookbooks/message-queue/index.html
index fadca30..32e4e8f 100644
--- a/content/docs/latest/cookbooks/message-queue/index.html
+++ b/content/docs/latest/cookbooks/message-queue/index.html
@@ -1071,9 +1071,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1301,6 +1301,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1379,8 +1381,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1437,9 +1437,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1599,9 +1599,9 @@
- <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
+ <li><a href="/docs/latest/clients/Python/">The Pulsar Python client</a></li>
@@ -1621,9 +1621,9 @@
- <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
+ <li><a href="/docs/latest/clients/WebSocket/">Pulsar's WebSocket API</a></li>
@@ -2079,9 +2079,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -2107,9 +2107,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/latest/cookbooks/tiered-storage/index.html b/content/docs/latest/cookbooks/tiered-storage/index.html
index 48e4971..d2419ee 100644
--- a/content/docs/latest/cookbooks/tiered-storage/index.html
+++ b/content/docs/latest/cookbooks/tiered-storage/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/deployment/Kubernetes/index.html b/content/docs/latest/deployment/Kubernetes/index.html
index 82e2140..868a18b 100644
--- a/content/docs/latest/deployment/Kubernetes/index.html
+++ b/content/docs/latest/deployment/Kubernetes/index.html
@@ -1051,9 +1051,9 @@
- <li><a href="/docs/latest/deployment/Kubernetes/">Deploying Pulsar on Kubernetes</a></li>
+ <li><a href="/docs/latest/deployment/Kubernetes/">Deploying Pulsar on Kubernetes</a></li>
@@ -1297,9 +1297,9 @@
- <li><a href="/docs/latest/deployment/Kubernetes/">Deploying Pulsar on Kubernetes</a></li>
+ <li><a href="/docs/latest/deployment/Kubernetes/">Deploying Pulsar on Kubernetes</a></li>
diff --git a/content/docs/latest/deployment/aws-cluster/index.html b/content/docs/latest/deployment/aws-cluster/index.html
index de4900b..47a5a53 100644
--- a/content/docs/latest/deployment/aws-cluster/index.html
+++ b/content/docs/latest/deployment/aws-cluster/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/deployment/cluster/index.html b/content/docs/latest/deployment/cluster/index.html
index 5149139..3113ea1 100644
--- a/content/docs/latest/deployment/cluster/index.html
+++ b/content/docs/latest/deployment/cluster/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/deployment/instance/index.html b/content/docs/latest/deployment/instance/index.html
index dfec2dd..9a49d19 100644
--- a/content/docs/latest/deployment/instance/index.html
+++ b/content/docs/latest/deployment/instance/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
diff --git a/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html b/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
index c7b2dad..51203a8 100644
--- a/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
+++ b/content/docs/latest/getting-started/ConceptsAndArchitecture/index.html
@@ -1021,9 +1021,9 @@
- <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
+ <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
@@ -1267,9 +1267,9 @@
- <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
+ <li><a href="/docs/latest/getting-started/ConceptsAndArchitecture/">Pulsar concepts and architecture</a></li>
diff --git a/content/docs/latest/getting-started/LocalCluster/index.html b/content/docs/latest/getting-started/LocalCluster/index.html
index dcceda6..564bdd5 100644
--- a/content/docs/latest/getting-started/LocalCluster/index.html
+++ b/content/docs/latest/getting-started/LocalCluster/index.html
@@ -1057,9 +1057,9 @@
- <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
+ <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
@@ -1305,9 +1305,9 @@
- <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
+ <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
diff --git a/content/docs/latest/getting-started/Pulsar-2.0/index.html b/content/docs/latest/getting-started/Pulsar-2.0/index.html
index 2018e47..45ec5ca 100644
--- a/content/docs/latest/getting-started/Pulsar-2.0/index.html
+++ b/content/docs/latest/getting-started/Pulsar-2.0/index.html
@@ -1563,9 +1563,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
diff --git a/content/docs/latest/getting-started/docker/index.html b/content/docs/latest/getting-started/docker/index.html
index 9a57076..6df1b14 100644
--- a/content/docs/latest/getting-started/docker/index.html
+++ b/content/docs/latest/getting-started/docker/index.html
@@ -1057,9 +1057,9 @@
- <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
+ <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
@@ -1305,9 +1305,9 @@
- <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
+ <li><a href="/docs/latest/getting-started/LocalCluster/">Setting up a local standalone cluster</a></li>
diff --git a/content/docs/latest/project/BinaryProtocol/index.html b/content/docs/latest/project/BinaryProtocol/index.html
index 5d74a12..3e28b29 100644
--- a/content/docs/latest/project/BinaryProtocol/index.html
+++ b/content/docs/latest/project/BinaryProtocol/index.html
@@ -1001,9 +1001,9 @@
- <li><a href="/docs/latest/project/BinaryProtocol/">Pulsar binary protocol specification</a></li>
+ <li><a href="/docs/latest/project/BinaryProtocol/">Pulsar binary protocol specification</a></li>
@@ -1247,9 +1247,9 @@
- <li><a href="/docs/latest/project/BinaryProtocol/">Pulsar binary protocol specification</a></li>
+ <li><a href="/docs/latest/project/BinaryProtocol/">Pulsar binary protocol specification</a></li>
diff --git a/content/docs/latest/project/CompileCpp/index.html b/content/docs/latest/project/CompileCpp/index.html
index 0b1376a..bd1db5f 100644
--- a/content/docs/latest/project/CompileCpp/index.html
+++ b/content/docs/latest/project/CompileCpp/index.html
@@ -1005,9 +1005,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1033,6 +1033,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1155,8 +1157,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
@@ -1287,9 +1287,9 @@
- <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
+ <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
diff --git a/content/docs/latest/project/SimulationTools/index.html b/content/docs/latest/project/SimulationTools/index.html
index 8857516..e601624 100644
--- a/content/docs/latest/project/SimulationTools/index.html
+++ b/content/docs/latest/project/SimulationTools/index.html
@@ -1099,9 +1099,9 @@
- <li><a href="/docs/latest/project/SimulationTools/">Simulation tools</a></li>
+ <li><a href="/docs/latest/project/SimulationTools/">Simulation tools</a></li>
diff --git a/content/docs/latest/project/schema-storage/index.html b/content/docs/latest/project/schema-storage/index.html
index 9d6b5fd..333ed51 100644
--- a/content/docs/latest/project/schema-storage/index.html
+++ b/content/docs/latest/project/schema-storage/index.html
@@ -1045,9 +1045,9 @@
- <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
+ <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -1293,9 +1293,9 @@
- <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
+ <li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
diff --git a/content/docs/latest/reference/CliTools/index.html b/content/docs/latest/reference/CliTools/index.html
index cba50c3..1f6ea9f 100644
--- a/content/docs/latest/reference/CliTools/index.html
+++ b/content/docs/latest/reference/CliTools/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1271,9 +1271,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1439,9 +1439,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -1519,9 +1519,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1547,6 +1547,8 @@
+
+
<li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
@@ -1669,8 +1671,6 @@
-
-
<li><a href="/docs/latest/clients/go/">The Pulsar Go client</a></li>
@@ -1775,9 +1775,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -2021,9 +2021,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -2267,9 +2267,9 @@
- <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
+ <li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
diff --git a/content/docs/latest/security/authorization/index.html b/content/docs/latest/security/authorization/index.html
index e03f92f..538bda7 100644
--- a/content/docs/latest/security/authorization/index.html
+++ b/content/docs/latest/security/authorization/index.html
@@ -1005,6 +1005,8 @@
+
+
<li><a href="/docs/latest/reference/CliTools/">Pulsar command-line tools</a></li>
@@ -1123,8 +1125,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -1189,9 +1189,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -2299,6 +2299,8 @@
+
+
<li><a href="/docs/latest/clients/Java/">The Pulsar Java client</a></li>
@@ -2377,8 +2379,6 @@
-
-
<li><a href="/docs/latest/security/authorization/">Authentication and authorization in Pulsar</a></li>
@@ -2435,9 +2435,9 @@
- <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
+ <li><a href="/docs/latest/admin-api/overview/">The Pulsar admin interface</a></li>
@@ -2541,9 +2541,9 @@
- <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
+ <li><a href="/docs/latest/clients/Cpp/">The Pulsar C++ client</a></li>
diff --git a/content/docs/latest/security/encryption/index.html b/content/docs/latest/security/encryption/index.html
index a6132a3..18ca402 100644
--- a/content/docs/latest/security/encryption/index.html
+++ b/content/docs/latest/security/encryption/index.html
@@ -1567,9 +1567,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1823,9 +1823,9 @@
- <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
+ <li><a href="/docs/latest/cookbooks/PartitionedTopics/">Partitioned topics</a></li>
@@ -1851,9 +1851,9 @@
- <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
+ <li><a href="/docs/latest/cookbooks/RetentionExpiry/">Message retention and expiry</a></li>
diff --git a/content/docs/zh-CN/2.1.0-incubating/adaptors-storm.html b/content/docs/zh-CN/2.1.0-incubating/adaptors-storm.html
index baad1f6..de8b986 100644
--- a/content/docs/zh-CN/2.1.0-incubating/adaptors-storm.html
+++ b/content/docs/zh-CN/2.1.0-incubating/adaptors-storm.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.1.0-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.1.0-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核 [...]
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adapt [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/2.1.0-incubating/adaptors-storm/index.html b/content/docs/zh-CN/2.1.0-incubating/adaptors-storm/index.html
index baad1f6..de8b986 100644
--- a/content/docs/zh-CN/2.1.0-incubating/adaptors-storm/index.html
+++ b/content/docs/zh-CN/2.1.0-incubating/adaptors-storm/index.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.1.0-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.1.0-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核 [...]
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adapt [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.0-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.0-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/2.1.1-incubating/adaptors-storm.html b/content/docs/zh-CN/2.1.1-incubating/adaptors-storm.html
index a1a4471..ce3b988 100644
--- a/content/docs/zh-CN/2.1.1-incubating/adaptors-storm.html
+++ b/content/docs/zh-CN/2.1.1-incubating/adaptors-storm.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.1.1-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.1.1-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核 [...]
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adapt [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/2.1.1-incubating/adaptors-storm/index.html b/content/docs/zh-CN/2.1.1-incubating/adaptors-storm/index.html
index a1a4471..ce3b988 100644
--- a/content/docs/zh-CN/2.1.1-incubating/adaptors-storm/index.html
+++ b/content/docs/zh-CN/2.1.1-incubating/adaptors-storm/index.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.1.1-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.1.1-incubating"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核 [...]
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/incubator-pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adapt [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/2.1.1-incubating/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/2.1.1-incubating/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/adaptors-storm.html b/content/docs/zh-CN/adaptors-storm.html
index 4c09c8a..34f4903 100644
--- a/content/docs/zh-CN/adaptors-storm.html
+++ b/content/docs/zh-CN/adaptors-storm.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.2.0"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologie [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.2.0"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adaptor</a></li><li><a href="#pulsar-sp [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li><a href="#pulsar-spout">Pulsar Sp [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/adaptors-storm/index.html b/content/docs/zh-CN/adaptors-storm/index.html
index 4c09c8a..34f4903 100644
--- a/content/docs/zh-CN/adaptors-storm/index.html
+++ b/content/docs/zh-CN/adaptors-storm/index.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="2.2.0"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologie [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="2.2.0"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adaptor</a></li><li><a href="#pulsar-sp [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li><a href="#pulsar-spout">Pulsar Sp [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/next/adaptors-storm.html b/content/docs/zh-CN/next/adaptors-storm.html
index 5371ac4..4ee83b2 100644
--- a/content/docs/zh-CN/next/adaptors-storm.html
+++ b/content/docs/zh-CN/next/adaptors-storm.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="next"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="next"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/next/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adaptor</a></li><li><a href=" [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/next/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li><a href="#pulsar-spout" [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/next/adaptors-storm/index.html b/content/docs/zh-CN/next/adaptors-storm/index.html
index 5371ac4..4ee83b2 100644
--- a/content/docs/zh-CN/next/adaptors-storm/index.html
+++ b/content/docs/zh-CN/next/adaptors-storm/index.html
@@ -1,5 +1,5 @@
-<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provides core Storm implementations [...]
-"/><meta name="docsearch:version" content="next"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies [...]
+<!DOCTYPE html><html lang="zh-CN"><head><meta charSet="utf-8"/><meta http-equiv="X-UA-Compatible" content="IE=edge"/><title>Pulsar adaptor for Apache Storm · Apache Pulsar</title><meta name="viewport" content="width=device-width"/><meta name="generator" content="Docusaurus"/><meta name="description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
+"/><meta name="docsearch:version" content="next"/><meta name="docsearch:language" content="zh-CN"/><meta property="og:title" content="Pulsar adaptor for Apache Storm · Apache Pulsar"/><meta property="og:type" content="website"/><meta property="og:url" content="https://pulsar.incubator.apache.org/index.html"/><meta property="og:description" content="<p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
"/><meta name="twitter:card" content="summary"/><meta name="twitter:image" content="https://pulsar.incubator.apache.org/img/pulsar.svg"/><link rel="shortcut icon" href="/img/pulsar.ico"/><link rel="stylesheet" href="https://cdn.jsdelivr.net/docsearch.js/1/docsearch.min.css"/><link rel="stylesheet" href="//cdnjs.cloudflare.com/ajax/libs/highlight.js/9.12.0/styles/atom-one-dark.min.css"/><link rel="alternate" type="application/atom+xml" href="https://pulsar.incubator.apache.org/blog/atom.x [...]
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
@@ -47,10 +47,10 @@
};
}
});
- </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm is an adaptor for integrating with <a href="http://storm.apache.org/">Apache Storm</a> topologies. It provid [...]
+ </script></nav></div><div class="container mainContainer"><div class="wrapper"><div class="post"><header class="postHeader"><a class="edit-page-link button" href="https://crowdin.com/project/apache-pulsar/zh-CN" target="_blank" rel="noreferrer noopener">Translate</a><h1 class="postHeaderTitle">Pulsar adaptor for Apache Storm</h1></header><article><div><span><p>Pulsar Storm 是一个用来整合 <a href="http://storm.apache.org/">Apache Storm</a> 的适配扩展.它提供 Storm 发送和接收数据的核心实现.</p>
<p>An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.</p>
-<h2><a class="anchor" aria-hidden="true" id="using-the-pulsar-storm-adaptor"></a><a href="#using-the-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 1 [...]
-<p>Include dependency for Pulsar Storm Adaptor:</p>
+<h2><a class="anchor" aria-hidden="true" id="使用-pulsar-storm-adaptor"></a><a href="#使用-pulsar-storm-adaptor" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 [...]
+<p>引入 Pulsar Storm Adaptor 依赖:</p>
<pre><code class="hljs css language-xml"><span class="hljs-tag"><<span class="hljs-name">dependency</span>></span>
<span class="hljs-tag"><<span class="hljs-name">groupId</span>></span>org.apache.pulsar<span class="hljs-tag"></<span class="hljs-name">groupId</span>></span>
<span class="hljs-tag"><<span class="hljs-name">artifactId</span>></span>pulsar-storm<span class="hljs-tag"></<span class="hljs-name">artifactId</span>></span>
@@ -58,7 +58,7 @@
<span class="hljs-tag"></<span class="hljs-name">dependency</span>></span>
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="pulsar-spout"></a><a href="#pulsar-spout" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83. [...]
-<p>The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
+<p>Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the <code>MessageToValuesMapper</code> provided by the client.</p>
<p>The tuples that fail to be processed by the downstream bolts will be re-injected by the spout with an exponential backoff, within a configurable timeout (the default is 60 seconds) or a configurable number of retries, whichever comes first, after which it is acknowledged by the consumer. Here's an example construction of a spout:</p>
<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
@@ -94,10 +94,10 @@ PulsarSpout spout = <span class="hljs-keyword">new</span> PulsarSpout(spoutConf,
<h2><a class="anchor" aria-hidden="true" id="pulsar-bolt"></a><a href="#pulsar-bolt" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42 [...]
<p>The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the <code>TupleToMessageMapper</code> provided by the client.</p>
<p>A partitioned topic can also be used to publish messages on different topics. In the implementation of the <code>TupleToMessageMapper</code>, a "key" will need to be provided in the message which will send the messages with the same key to the same topic. Here's an example bolt:</p>
-<pre><code class="hljs css language-java"><span class="hljs-comment">// Configure a Pulsar Client</span>
+<pre><code class="hljs css language-java"><span class="hljs-comment">// 配置一个 Pulsar Client</span>
ClientConfiguration clientConf = <span class="hljs-keyword">new</span> ClientConfiguration();
-<span class="hljs-comment">// Configure a Pulsar Producer </span>
+<span class="hljs-comment">// 配置一个 Pulsar Producer </span>
ProducerConfiguration producerConf = <span class="hljs-keyword">new</span> ProducerConfiguration();
<span class="hljs-meta">@SuppressWarnings</span>(<span class="hljs-string">"serial"</span>)
@@ -106,29 +106,29 @@ TupleToMessageMapper tupleToMessageMapper = <span class="hljs-keyword">new</span
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> Message <span class="hljs-title">toMessage</span><span class="hljs-params">(Tuple tuple)</span> </span>{
String receivedMessage = tuple.getString(<span class="hljs-number">0</span>);
- <span class="hljs-comment">// message processing</span>
+ <span class="hljs-comment">// 处理消息</span>
String processedMsg = receivedMessage + <span class="hljs-string">"-processed"</span>;
<span class="hljs-keyword">return</span> MessageBuilder.create().setContent(processedMsg.getBytes()).build();
}
<span class="hljs-meta">@Override</span>
<span class="hljs-function"><span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title">declareOutputFields</span><span class="hljs-params">(OutputFieldsDeclarer declarer)</span> </span>{
- <span class="hljs-comment">// declare the output fields</span>
+ <span class="hljs-comment">// 声明输出字段</span>
}
};
-<span class="hljs-comment">// Configure a Pulsar Bolt</span>
+<span class="hljs-comment">// 配置一个 Pulsar Bolt</span>
PulsarBoltConfiguration boltConf = <span class="hljs-keyword">new</span> PulsarBoltConfiguration();
boltConf.setServiceUrl(<span class="hljs-string">"pulsar://broker.messaging.usw.example.com:6650"</span>);
boltConf.setTopic(<span class="hljs-string">"persistent://my-property/usw/my-ns/my-topic2"</span>);
boltConf.setTupleToMessageMapper(tupleToMessageMapper);
-<span class="hljs-comment">// Create a Pulsar Bolt</span>
+<span class="hljs-comment">// 创建一个 Pulsar Bolt</span>
PulsarBolt bolt = <span class="hljs-keyword">new</span> PulsarBolt(boltConf, clientConf);
</code></pre>
<h2><a class="anchor" aria-hidden="true" id="example"></a><a href="#example" aria-hidden="true" class="hash-link"><svg class="hash-link-icon" aria-hidden="true" height="16" version="1.1" viewBox="0 0 16 16" width="16"><path fill-rule="evenodd" d="M4 9h1v1H4c-1.5 0-3-1.69-3-3.5S2.55 3 4 3h4c1.45 0 3 1.69 3 3.5 0 1.41-.91 2.72-2 3.25V8.59c.58-.45 1-1.27 1-2.09C10 5.22 8.98 4 8 4H4c-.98 0-2 1.22-2 2.5S3 9 4 9zm9-3h-1v1h1c1 0 2 1.22 2 2.5S13.98 12 13 12H9c-.98 0-2-1.22-2-2.5 0-.83.42-1.64 1- [...]
<p>You can find a complete example <a href="https://github.com/apache/pulsar/tree/master/pulsar-storm/src/test/java/org/apache/pulsar/storm/example/StormExample.java">here</a>.</p>
-</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/next/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#using-the-pulsar-storm-adaptor">Using the Pulsar Storm Adaptor</a></li><li><a href=" [...]
+</span></div></article></div><div class="docs-prevnext"><a class="docs-prev button" href="/docs/zh-CN/next/adaptors-spark"><span class="arrow-prev">← </span><span>Apache Spark</span></a><a class="docs-next button" href="/docs/zh-CN/next/cookbooks-tiered-storage"><span>Tiered Storage</span><span class="arrow-next"> →</span></a></div></div></div><nav class="onPageNav"><ul class="toc-headings"><li><a href="#使用-pulsar-storm-adaptor">使用 Pulsar Storm Adaptor</a></li><li><a href="#pulsar-spout" [...]
const community = document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/ja/adaptors/PulsarSpark/index.html b/content/ja/adaptors/PulsarSpark/index.html
index 51c3895..34dd969 100644
--- a/content/ja/adaptors/PulsarSpark/index.html
+++ b/content/ja/adaptors/PulsarSpark/index.html
@@ -762,9 +762,9 @@
+ <li><a href="/ja/adaptors/PulsarSpark/">Spark Streaming Pulsar Receiver</a></li>
- <li><a href="/ja/adaptors/PulsarSpark/">Spark Streaming Pulsar Receiver</a></li>
@@ -1008,9 +1008,9 @@
+ <li><a href="/ja/adaptors/PulsarSpark/">Spark Streaming Pulsar Receiver</a></li>
- <li><a href="/ja/adaptors/PulsarSpark/">Spark Streaming Pulsar Receiver</a></li>
@@ -1224,8 +1224,6 @@
-
-
<li><a href="/ja/clients/Java/">Pulsar Javaクライアント</a></li>
@@ -1387,6 +1385,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/adaptors/PulsarStorm/index.html b/content/ja/adaptors/PulsarStorm/index.html
index 8d8ca73..d24d155 100644
--- a/content/ja/adaptors/PulsarStorm/index.html
+++ b/content/ja/adaptors/PulsarStorm/index.html
@@ -766,9 +766,9 @@
+ <li><a href="/ja/adaptors/PulsarStorm/">Apache StormのためのPulsarアダプタ</a></li>
- <li><a href="/ja/adaptors/PulsarStorm/">Apache StormのためのPulsarアダプタ</a></li>
@@ -978,8 +978,6 @@
-
-
<li><a href="/ja/clients/Java/">Pulsar Javaクライアント</a></li>
@@ -1141,6 +1139,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/admin/AdminInterface/index.html b/content/ja/admin/AdminInterface/index.html
index 9a1d3fa..5a8fbe4 100644
--- a/content/ja/admin/AdminInterface/index.html
+++ b/content/ja/admin/AdminInterface/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -950,9 +950,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1486,8 +1486,6 @@
-
-
<li><a href="/ja/clients/Java/">Pulsar Javaクライアント</a></li>
@@ -1649,6 +1647,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/admin/Authz/index.html b/content/ja/admin/Authz/index.html
index f31d19b..910e23f 100644
--- a/content/ja/admin/Authz/index.html
+++ b/content/ja/admin/Authz/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -1976,8 +1976,6 @@
-
-
<li><a href="/ja/clients/Java/">Pulsar Javaクライアント</a></li>
@@ -2139,6 +2137,8 @@
+
+
</ul>
</div>
</div>
@@ -2212,9 +2212,9 @@
+ <li><a href="/ja/clients/Cpp/">Pulsar C++クライアント</a></li>
- <li><a href="/ja/clients/Cpp/">Pulsar C++クライアント</a></li>
diff --git a/content/ja/admin/ClustersBrokers/index.html b/content/ja/admin/ClustersBrokers/index.html
index 0c37b98..ad4bdb4 100644
--- a/content/ja/admin/ClustersBrokers/index.html
+++ b/content/ja/admin/ClustersBrokers/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
diff --git a/content/ja/admin/PropertiesNamespaces/index.html b/content/ja/admin/PropertiesNamespaces/index.html
index 050393b..807551e 100644
--- a/content/ja/admin/PropertiesNamespaces/index.html
+++ b/content/ja/admin/PropertiesNamespaces/index.html
@@ -1184,9 +1184,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1254,9 +1254,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -1284,9 +1284,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
diff --git a/content/ja/advanced/PartitionedTopics/index.html b/content/ja/advanced/PartitionedTopics/index.html
index 3ab5407..4297a12 100644
--- a/content/ja/advanced/PartitionedTopics/index.html
+++ b/content/ja/advanced/PartitionedTopics/index.html
@@ -752,9 +752,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -998,9 +998,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -1184,9 +1184,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1254,9 +1254,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -1284,9 +1284,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -1504,9 +1504,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
diff --git a/content/ja/advanced/RetentionExpiry/index.html b/content/ja/advanced/RetentionExpiry/index.html
index eb7d4b0..fd6137c 100644
--- a/content/ja/advanced/RetentionExpiry/index.html
+++ b/content/ja/advanced/RetentionExpiry/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -1038,9 +1038,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -1284,9 +1284,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -1530,9 +1530,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
diff --git a/content/ja/clients/Cpp/index.html b/content/ja/clients/Cpp/index.html
index e51d5eb..e6411a1 100644
--- a/content/ja/clients/Cpp/index.html
+++ b/content/ja/clients/Cpp/index.html
@@ -688,8 +688,6 @@
-
-
<li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -893,6 +891,8 @@
+
+
</ul>
</div>
</div>
@@ -966,9 +966,9 @@
+ <li><a href="/ja/clients/Cpp/">Pulsar C++クライアント</a></li>
- <li><a href="/ja/clients/Cpp/">Pulsar C++クライアント</a></li>
diff --git a/content/ja/clients/Java/index.html b/content/ja/clients/Java/index.html
index 2a626c7..e543182 100644
--- a/content/ja/clients/Java/index.html
+++ b/content/ja/clients/Java/index.html
@@ -688,8 +688,6 @@
-
-
<li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -893,6 +891,8 @@
+
+
</ul>
</div>
</div>
@@ -984,8 +984,6 @@
-
-
<li><a href="/ja/clients/Java/">Pulsar Javaクライアント</a></li>
@@ -1147,6 +1145,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/clients/Python/index.html b/content/ja/clients/Python/index.html
index b937ecf..ed49516 100644
--- a/content/ja/clients/Python/index.html
+++ b/content/ja/clients/Python/index.html
@@ -688,8 +688,6 @@
-
-
<li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -893,6 +891,8 @@
+
+
</ul>
</div>
</div>
@@ -1022,8 +1022,6 @@
-
-
<li><a href="/ja/clients/Python/">Pulsar Pythonクライアント</a></li>
@@ -1141,6 +1139,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/clients/WebSocket/index.html b/content/ja/clients/WebSocket/index.html
index ee0d865..b7b7730 100644
--- a/content/ja/clients/WebSocket/index.html
+++ b/content/ja/clients/WebSocket/index.html
@@ -790,9 +790,9 @@
+ <li><a href="/ja/clients/WebSocket/">PulsarにおけるWebSocket API</a></li>
- <li><a href="/ja/clients/WebSocket/">PulsarにおけるWebSocket API</a></li>
@@ -1036,9 +1036,9 @@
+ <li><a href="/ja/clients/WebSocket/">PulsarにおけるWebSocket API</a></li>
- <li><a href="/ja/clients/WebSocket/">PulsarにおけるWebSocket API</a></li>
@@ -1262,8 +1262,6 @@
-
-
<li><a href="/ja/clients/Python/">Pulsar Pythonクライアント</a></li>
@@ -1381,6 +1379,8 @@
+
+
</ul>
</div>
</div>
diff --git a/content/ja/deployment/InstanceSetup/index.html b/content/ja/deployment/InstanceSetup/index.html
index d12999b..6499654 100644
--- a/content/ja/deployment/InstanceSetup/index.html
+++ b/content/ja/deployment/InstanceSetup/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
diff --git a/content/ja/deployment/Kubernetes/index.html b/content/ja/deployment/Kubernetes/index.html
index 4dd17d9..dd736d4 100644
--- a/content/ja/deployment/Kubernetes/index.html
+++ b/content/ja/deployment/Kubernetes/index.html
@@ -734,9 +734,9 @@
+ <li><a href="/ja/deployment/Kubernetes/">Kubernetes上でのPulsarのデプロイ</a></li>
- <li><a href="/ja/deployment/Kubernetes/">Kubernetes上でのPulsarのデプロイ</a></li>
@@ -980,9 +980,9 @@
+ <li><a href="/ja/deployment/Kubernetes/">Kubernetes上でのPulsarのデプロイ</a></li>
- <li><a href="/ja/deployment/Kubernetes/">Kubernetes上でのPulsarのデプロイ</a></li>
diff --git a/content/ja/getting-started/ConceptsAndArchitecture/index.html b/content/ja/getting-started/ConceptsAndArchitecture/index.html
index 0efaab5..6c57f6a 100644
--- a/content/ja/getting-started/ConceptsAndArchitecture/index.html
+++ b/content/ja/getting-started/ConceptsAndArchitecture/index.html
@@ -704,9 +704,9 @@
+ <li><a href="/ja/getting-started/ConceptsAndArchitecture/">Pulsarのコンセプトとアーキテクチャ</a></li>
- <li><a href="/ja/getting-started/ConceptsAndArchitecture/">Pulsarのコンセプトとアーキテクチャ</a></li>
diff --git a/content/ja/getting-started/LocalCluster/index.html b/content/ja/getting-started/LocalCluster/index.html
index bcf9413..f3a8dca 100644
--- a/content/ja/getting-started/LocalCluster/index.html
+++ b/content/ja/getting-started/LocalCluster/index.html
@@ -740,9 +740,9 @@
+ <li><a href="/ja/getting-started/LocalCluster/">ローカルスタンドアローンクラスタのセットアップ</a></li>
- <li><a href="/ja/getting-started/LocalCluster/">ローカルスタンドアローンクラスタのセットアップ</a></li>
@@ -986,9 +986,9 @@
+ <li><a href="/ja/getting-started/LocalCluster/">ローカルスタンドアローンクラスタのセットアップ</a></li>
- <li><a href="/ja/getting-started/LocalCluster/">ローカルスタンドアローンクラスタのセットアップ</a></li>
diff --git a/content/ja/project/BinaryProtocol/index.html b/content/ja/project/BinaryProtocol/index.html
index f595218..642f8fd 100644
--- a/content/ja/project/BinaryProtocol/index.html
+++ b/content/ja/project/BinaryProtocol/index.html
@@ -684,9 +684,9 @@
+ <li><a href="/ja/project/BinaryProtocol/">Pulsarのバイナリプロトコルの仕様</a></li>
- <li><a href="/ja/project/BinaryProtocol/">Pulsarのバイナリプロトコルの仕様</a></li>
@@ -930,9 +930,9 @@
+ <li><a href="/ja/project/BinaryProtocol/">Pulsarのバイナリプロトコルの仕様</a></li>
- <li><a href="/ja/project/BinaryProtocol/">Pulsarのバイナリプロトコルの仕様</a></li>
diff --git a/content/ja/project/SimulationTools/index.html b/content/ja/project/SimulationTools/index.html
index b9b8152..e5a28bb 100644
--- a/content/ja/project/SimulationTools/index.html
+++ b/content/ja/project/SimulationTools/index.html
@@ -782,9 +782,9 @@
+ <li><a href="/ja/project/SimulationTools/">シミュレーションツール</a></li>
- <li><a href="/ja/project/SimulationTools/">シミュレーションツール</a></li>
diff --git a/content/ja/reference/CliTools/index.html b/content/ja/reference/CliTools/index.html
index 97c8e05..eb25626 100644
--- a/content/ja/reference/CliTools/index.html
+++ b/content/ja/reference/CliTools/index.html
@@ -692,9 +692,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -762,9 +762,9 @@
+ <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
- <li><a href="/ja/advanced/PartitionedTopics/">パーティションドトピック</a></li>
@@ -792,9 +792,9 @@
+ <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
- <li><a href="/ja/advanced/RetentionExpiry/">メッセージの保存と有効期限</a></li>
@@ -950,9 +950,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1196,8 +1196,6 @@
-
-
<li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1401,6 +1399,8 @@
+
+
</ul>
</div>
</div>
@@ -1448,9 +1448,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1694,9 +1694,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
@@ -1940,9 +1940,9 @@
+ <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
- <li><a href="/ja/reference/CliTools/">Pulsarコマンドラインツール</a></li>
diff --git a/content/swagger/swagger.json b/content/swagger/swagger.json
index 1adc6f9..f620187 100644
--- a/content/swagger/swagger.json
+++ b/content/swagger/swagger.json
@@ -6652,10 +6652,10 @@
"type" : "string"
}
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
"address" : {
@@ -6978,31 +6978,28 @@
"type" : "number",
"format" : "double"
},
- "overLoaded" : {
- "type" : "boolean"
- },
- "cpu" : {
+ "directMemory" : {
"$ref" : "#/definitions/ResourceUsage"
},
"underLoaded" : {
"type" : "boolean"
},
- "bandwidthIn" : {
+ "cpu" : {
"$ref" : "#/definitions/ResourceUsage"
},
+ "lastUpdate" : {
+ "type" : "integer",
+ "format" : "int64"
+ },
"bandwidthOut" : {
"$ref" : "#/definitions/ResourceUsage"
},
"memory" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "directMemory" : {
+ "bandwidthIn" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "lastUpdate" : {
- "type" : "integer",
- "format" : "int64"
- },
"msgThroughputIn" : {
"type" : "number",
"format" : "double"
@@ -7011,6 +7008,9 @@
"type" : "number",
"format" : "double"
},
+ "overLoaded" : {
+ "type" : "boolean"
+ },
"loadReportType" : {
"type" : "string"
}
@@ -7175,10 +7175,10 @@
"producerName" : {
"type" : "string"
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
"address" : {
@@ -7889,10 +7889,10 @@
"producerName" : {
"type" : "string"
},
- "clientVersion" : {
+ "connectedSince" : {
"type" : "string"
},
- "connectedSince" : {
+ "clientVersion" : {
"type" : "string"
},
"address" : {