Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
pulsar
提交
1d5ec83a
pulsar
项目概览
apache
/
pulsar
通知
129
Star
40
Fork
3
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Wiki
1
Wiki
分析
仓库
DevOps
项目成员
Pages
pulsar
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Pages
分析
分析
仓库分析
DevOps
Wiki
1
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
提交
体验新版 GitCode,发现更多精彩内容 >>
提交
1d5ec83a
编写于
3月 11, 2017
作者:
H
hrsakai
提交者:
Matteo Merli
3月 10, 2017
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
amend some typographic errors in documents (#286)
上级
75d2273e
变更
5
隐藏空白更改
内联
并排
Showing
5 changed file
with
12 addition
and
20 deletion
+12
-20
docs/AdminTools.md
docs/AdminTools.md
+7
-15
docs/BinaryProtocol.md
docs/BinaryProtocol.md
+1
-1
docs/ClusterSetup.md
docs/ClusterSetup.md
+2
-2
docs/GeoReplication.md
docs/GeoReplication.md
+1
-1
docs/WebSocket.md
docs/WebSocket.md
+1
-1
未找到文件。
docs/AdminTools.md
浏览文件 @
1d5ec83a
...
...
@@ -663,7 +663,7 @@ admin.clusters().deleteCluster(cluster)
#### list all clusters
It gives a list of
c
all created clusters in Pulsar system.
It gives a list of all created clusters in Pulsar system.
###### CLI
...
...
@@ -2386,10 +2386,6 @@ In your terminal, go to below directory to play with client tool.
<td>```
-m, --messages
```</td>
<td>```
Comma separted string messages to send. Cannot be used with -f. Either -m or -f must be provided
```</td>
</tr>
<tr>
<td>```
-np, --non-persistent
```</td>
<td>```
Produce non-persistent message, Default: false
```</td>
</tr>
<tr>
<td>```
-n, --num-produce
```</td>
<td>```
Number of times to send message(s), Default: 1
```</td>
...
...
@@ -2398,10 +2394,6 @@ In your terminal, go to below directory to play with client tool.
<td>```
-r, --rate
```</td>
<td>```
Rate (in msg/sec) at which to produce. Value of 0 will produce messages as fast as possible, Default: 0.0
```</td>
</tr>
<tr>
<td>```
--ttl
```</td>
<td>```
Time to live (in ms) for the messages. Value of 0 will result in unlimited TTL, Default: 3600000
```</td>
</tr>
<table>
#### consume message command
...
...
@@ -2414,10 +2406,6 @@ In your terminal, go to below directory to play with client tool.
<th>options</th>
<th>description</th>
</tr>
<tr>
<td>```
-c, --client-id
```</td>
<td>```
Client ID for subscriber connection. Required if subscriber ID also specified
```</td>
</tr>
<tr>
<td>```
--hex
```</td>
<td>```
Display binary messages in hex, Default: false
```</td>
...
...
@@ -2431,7 +2419,11 @@ In your terminal, go to below directory to play with client tool.
<td>```
Rate (in msg/sec) at which to consume. Value of 0 will consume messages as fast as possible, Default: 0.0
```</td>
</tr>
<tr>
<td>```
-s, --subscriber-id
```</td>
<td>```
Subscriber ID for a durable subscriber
```
</td>
<td>```
-s, --subscription-name
```</td>
<td>```
Subscription name
```</td>
</tr>
<tr>
<td>```
-t, --subscription-type
```</td>
<td>```
Subscription type: Exclusive, Shared, Failover, Default: Exclusive
```
</td>
</tr>
<table>
docs/BinaryProtocol.md
浏览文件 @
1d5ec83a
...
...
@@ -34,7 +34,7 @@ Commands for different producers and consumers can be interleaved and sent
through the same connection without any restriction.
All the commands are embedded in a
[
`BaseCommand`
](
https://github.com/yahoo/pulsar/blob/master/pulsar-common/src/main/proto/PulsarApi.proto#L
283
)
[
`BaseCommand`
](
https://github.com/yahoo/pulsar/blob/master/pulsar-common/src/main/proto/PulsarApi.proto#L
335
)
protobuf object that includes a type enum and all the possible sub-commands as
optional fields. At any time, one
`BaseCommand`
can only have set a single
sub-command.
...
...
docs/ClusterSetup.md
浏览文件 @
1d5ec83a
...
...
@@ -190,7 +190,7 @@ zkServers=zk1.example.com:2181,zk2.example.com:2181,zk3.example.com:2181
ledgerManagerType
=
hierarchical
```
Please consult
[
http://bookkeeper.apache.org/
](
)
for more extensive documentation
Please consult
http://bookkeeper.apache.org/
for more extensive documentation
on Apache BookKeeper.
##### Starting the service
...
...
@@ -317,7 +317,7 @@ for messages:
$
bin/pulsar-perf consume persistent://test/us-west/ns1/my-topic
```
Start a produce that publishes messages at a fixed rate and report stats every
Start a produce
r
that publishes messages at a fixed rate and report stats every
10 seconds:
```
shell
...
...
docs/GeoReplication.md
浏览文件 @
1d5ec83a
...
...
@@ -6,7 +6,7 @@
-
[
Replication model
](
#replication-model
)
-
[
Configuring replication
](
#configuring-replication
)
-
[
Granting permissions to properties
](
#granting-permissions-to-properties
)
-
[
Creating
the namespace
](
#creating-the-namespace
)
-
[
Creating
global namespaces
](
#creating-global-namespaces
)
-
[
Using global topics
](
#using-global-topics
)
<!-- /TOC -->
...
...
docs/WebSocket.md
浏览文件 @
1d5ec83a
...
...
@@ -121,7 +121,7 @@ http://{serviceUrl}:8080/ws/producer/persistent/{property}/{cluster}/{namespace}
### Consumer
Open a WebSocket session to create a
produc
er for a specific topic:
Open a WebSocket session to create a
consum
er for a specific topic:
```
perl
http:
//
{
serviceUrl
}:
8080
/ws/consum
er
/persistent/
{
property
}
/{cluster}/
{
namespace
}
/{topic}/
{
subscription
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录