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 f6c48cc Updated site at revision e8025d5
f6c48cc is described below
commit f6c48ccf0f25cf574c217a176832a164ed413e84
Author: jenkins <[email protected]>
AuthorDate: Thu Jul 4 09:09:08 2019 +0000
Updated site at revision e8025d5
---
content/docs/en/next/adaptors-kafka.html | 1 -
content/docs/en/next/adaptors-kafka/index.html | 1 -
content/docs/fr/next/adaptors-kafka.html | 1 -
content/docs/fr/next/adaptors-kafka/index.html | 1 -
content/docs/ja/next/adaptors-kafka.html | 1 -
content/docs/ja/next/adaptors-kafka/index.html | 1 -
content/docs/zh-CN/2.3.0/io-kafka.html | 4 +-
content/docs/zh-CN/2.3.0/io-kafka/index.html | 4 +-
content/docs/zh-CN/2.3.1/io-kafka.html | 4 +-
content/docs/zh-CN/2.3.1/io-kafka/index.html | 4 +-
content/docs/zh-CN/io-kafka.html | 4 +-
content/docs/zh-CN/io-kafka/index.html | 4 +-
content/docs/zh-CN/next/adaptors-kafka.html | 1 -
content/docs/zh-CN/next/adaptors-kafka/index.html | 1 -
content/docs/zh-CN/next/io-kafka.html | 12 +++---
content/docs/zh-CN/next/io-kafka/index.html | 12 +++---
content/swagger/2.5.0-SNAPSHOT/swagger.json | 46 ++++++++++++++--------
.../swagger/2.5.0-SNAPSHOT/swaggerfunctions.json | 28 ++++++-------
18 files changed, 68 insertions(+), 62 deletions(-)
diff --git a/content/docs/en/next/adaptors-kafka.html
b/content/docs/en/next/adaptors-kafka.html
index 9aa46d2..2f00e21 100644
--- a/content/docs/en/next/adaptors-kafka.html
+++ b/content/docs/en/next/adaptors-kafka.html
@@ -181,7 +181,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left">Durability and
quorum writes are configured at the namespace level</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">Will have a default
value of <code>latest</code> if user does not give specific setting.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">If true it will
block producer, otherwise an error is returned.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/en/next/adaptors-kafka/index.html
b/content/docs/en/next/adaptors-kafka/index.html
index 9aa46d2..2f00e21 100644
--- a/content/docs/en/next/adaptors-kafka/index.html
+++ b/content/docs/en/next/adaptors-kafka/index.html
@@ -181,7 +181,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left">Durability and
quorum writes are configured at the namespace level</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">Will have a default
value of <code>latest</code> if user does not give specific setting.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">If true it will
block producer, otherwise an error is returned.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/fr/next/adaptors-kafka.html
b/content/docs/fr/next/adaptors-kafka.html
index 452e8ad..45a80cf 100644
--- a/content/docs/fr/next/adaptors-kafka.html
+++ b/content/docs/fr/next/adaptors-kafka.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left">Durabilité et
quorum d'écriture sont configurés au niveau de l'espace de nommage</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Oui</td><td style="text-align:left">Aura une valeur par
défaut de <code>latest</code> si l'utilisateur ne donne pas de valeur
spécifique.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Oui</td><td style="text-align:left">Si à true, cela
bloquera le producteur, sinon une erreur sera retournée.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Oui</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/fr/next/adaptors-kafka/index.html
b/content/docs/fr/next/adaptors-kafka/index.html
index 452e8ad..45a80cf 100644
--- a/content/docs/fr/next/adaptors-kafka/index.html
+++ b/content/docs/fr/next/adaptors-kafka/index.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left">Durabilité et
quorum d'écriture sont configurés au niveau de l'espace de nommage</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Oui</td><td style="text-align:left">Aura une valeur par
défaut de <code>latest</code> si l'utilisateur ne donne pas de valeur
spécifique.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Oui</td><td style="text-align:left">Si à true, cela
bloquera le producteur, sinon une erreur sera retournée.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Oui</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignoré</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/ja/next/adaptors-kafka.html
b/content/docs/ja/next/adaptors-kafka.html
index d9ad14b..9e3b797 100644
--- a/content/docs/ja/next/adaptors-kafka.html
+++ b/content/docs/ja/next/adaptors-kafka.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left">Durability and
quorum writes are configured at the namespace level</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">Will have a default
value of <code>latest</code> if user does not give specific setting.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">If true it will
block producer, otherwise an error is returned.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/ja/next/adaptors-kafka/index.html
b/content/docs/ja/next/adaptors-kafka/index.html
index d9ad14b..9e3b797 100644
--- a/content/docs/ja/next/adaptors-kafka/index.html
+++ b/content/docs/ja/next/adaptors-kafka/index.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left">Durability and
quorum writes are configured at the namespace level</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">Will have a default
value of <code>latest</code> if user does not give specific setting.</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">If true it will
block producer, otherwise an error is returned.</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/zh-CN/2.3.0/io-kafka.html
b/content/docs/zh-CN/2.3.0/io-kafka.html
index fcdf5a5..ab56671 100644
--- a/content/docs/zh-CN/2.3.0/io-kafka.html
+++ b/content/docs/zh-CN/2.3.0/io-kafka.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/2.3.0/io-kafka/index.html
b/content/docs/zh-CN/2.3.0/io-kafka/index.html
index fcdf5a5..ab56671 100644
--- a/content/docs/zh-CN/2.3.0/io-kafka/index.html
+++ b/content/docs/zh-CN/2.3.0/io-kafka/index.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/2.3.1/io-kafka.html
b/content/docs/zh-CN/2.3.1/io-kafka.html
index 0d809a2..77c6fd3 100644
--- a/content/docs/zh-CN/2.3.1/io-kafka.html
+++ b/content/docs/zh-CN/2.3.1/io-kafka.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/2.3.1/io-kafka/index.html
b/content/docs/zh-CN/2.3.1/io-kafka/index.html
index 0d809a2..77c6fd3 100644
--- a/content/docs/zh-CN/2.3.1/io-kafka/index.html
+++ b/content/docs/zh-CN/2.3.1/io-kafka/index.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/io-kafka.html b/content/docs/zh-CN/io-kafka.html
index ff7f8ae..51fc578 100644
--- a/content/docs/zh-CN/io-kafka.html
+++ b/content/docs/zh-CN/io-kafka.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/io-kafka/index.html
b/content/docs/zh-CN/io-kafka/index.html
index ff7f8ae..51fc578 100644
--- a/content/docs/zh-CN/io-kafka/index.html
+++ b/content/docs/zh-CN/io-kafka/index.html
@@ -32,8 +32,8 @@
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为true，消费者则在后台定期提交offset。
This committed offset will be used when the process fails as the position from
which the new consumer will begin.</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>The
consumer config properties to be passed to Consumer. Note that other
properties specified in the connector config file take precedence over this
config.</td></tr>
diff --git a/content/docs/zh-CN/next/adaptors-kafka.html
b/content/docs/zh-CN/next/adaptors-kafka.html
index 100e61a..3ff5b6c 100644
--- a/content/docs/zh-CN/next/adaptors-kafka.html
+++ b/content/docs/zh-CN/next/adaptors-kafka.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">已忽略</td><td
style="text-align:left">持久性和法定写作已在命名空间级别上配置</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">若用户为提供特定设置，则默认值为
<code>latest</code> 。</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">值为 true
则中断生产者，否则将返回一个错误。</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/zh-CN/next/adaptors-kafka/index.html
b/content/docs/zh-CN/next/adaptors-kafka/index.html
index 100e61a..3ff5b6c 100644
--- a/content/docs/zh-CN/next/adaptors-kafka/index.html
+++ b/content/docs/zh-CN/next/adaptors-kafka/index.html
@@ -175,7 +175,6 @@ consumer.subscribe(Arrays.asList(topic));
<tr><td style="text-align:left"><code>acks</code></td><td
style="text-align:left">已忽略</td><td
style="text-align:left">持久性和法定写作已在命名空间级别上配置</td></tr>
<tr><td style="text-align:left"><code>auto.offset.reset</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">若用户为提供特定设置，则默认值为
<code>latest</code> 。</td></tr>
<tr><td style="text-align:left"><code>batch.size</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>block.on.buffer.full</code></td><td
style="text-align:left">Yes</td><td style="text-align:left">值为 true
则中断生产者，否则将返回一个错误。</td></tr>
<tr><td style="text-align:left"><code>bootstrap.servers</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>buffer.memory</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
<tr><td style="text-align:left"><code>client.id</code></td><td
style="text-align:left">已忽略</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/zh-CN/next/io-kafka.html
b/content/docs/zh-CN/next/io-kafka.html
index d0e3b87..cdb7f70 100644
--- a/content/docs/zh-CN/next/io-kafka.html
+++ b/content/docs/zh-CN/next/io-kafka.html
@@ -22,19 +22,19 @@
});
</script></span><li class="navSearchWrapper
reactNavSearchWrapper"><input type="text" id="search_input_react"
placeholder="Search"
title="Search"/></li></ul></nav></div></header></div></div><div
class="navPusher"><div class="docMainWrapper wrapper"><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">Tran [...]
<p>Kafka Source Connector 用于从 Kafka 的主题中拉取消息并持久化到 Pulsar 主题中。</p>
-<h3><a class="anchor" aria-hidden="true"
id="source-configuration-options"></a><a href="#source-configuration-options"
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 [...]
+<h3><a class="anchor" aria-hidden="true" id="source-配置选项"></a><a
href="#source-配置选项" 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
[...]
<table>
<thead>
-<tr><th>Name</th><th>Required</th><th>默认值</th><th>说明：</th></tr>
+<tr><th>Name</th><th>Required</th><th>Default</th><th>Description</th></tr>
</thead>
<tbody>
<tr><td>bootstrapServers</td><td><code>true</code></td><td><code>null</code></td><td>用于建立与
Kafka 集群初始连接的主机/端口对列表。</td></tr>
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为
true，消费者的偏移量会在后台定期提交。如果处理失败，新的消费者将使用已提交的偏移量作为消费开始的位置。</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
-<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
+<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>使用
Kafka 组管理设施时，检测消费者故障的超时。</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>要传递给
Consumer 的消费者配置属性。 请注意，connector 配置文件中指定的其他属性优先于此配置</td></tr>
<tr><td>keyDeserializationClass</td><td><code>false</code></td><td><code>valueDeserializationClass</code></td><td>Key的实现了
org.apache.kafka.common.serialization.Deserializer 接口的反序列化类。</td></tr>
@@ -59,7 +59,7 @@
<tr><td>valueSerializerClass</td><td><code>false</code></td><td><code>org.apache.kafka.common.serialization.ByteArraySerializer</code></td><td>Serializer
class for value that implements the
org.apache.kafka.common.serialization.Serializer interface.</td></tr>
</tbody>
</table>
-</span></div></article></div><div class="docs-prevnext"></div></div></div><nav
class="onPageNav"><ul class="toc-headings"><li><a href="#source">Source</a><ul
class="toc-headings"><li><a href="#source-configuration-options">Source
Configuration Options</a></li></ul></li><li><a href="#sink">Sink</a><ul
class="toc-headings"><li><a href="#sink-configuration-options">Sink
Configuration Options</a></li></ul></li></ul></nav></div><footer
class="nav-footer" id="footer"><section class="copyright" [...]
+</span></div></article></div><div class="docs-prevnext"></div></div></div><nav
class="onPageNav"><ul class="toc-headings"><li><a href="#source">Source</a><ul
class="toc-headings"><li><a href="#source-配置选项">Source
配置选项</a></li></ul></li><li><a href="#sink">Sink</a><ul
class="toc-headings"><li><a href="#sink-configuration-options">Sink
Configuration Options</a></li></ul></li></ul></nav></div><footer
class="nav-footer" id="footer"><section class="copyright">Copyright © 2019 The
Apache Softw [...]
const community =
document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/docs/zh-CN/next/io-kafka/index.html
b/content/docs/zh-CN/next/io-kafka/index.html
index d0e3b87..cdb7f70 100644
--- a/content/docs/zh-CN/next/io-kafka/index.html
+++ b/content/docs/zh-CN/next/io-kafka/index.html
@@ -22,19 +22,19 @@
});
</script></span><li class="navSearchWrapper
reactNavSearchWrapper"><input type="text" id="search_input_react"
placeholder="Search"
title="Search"/></li></ul></nav></div></header></div></div><div
class="navPusher"><div class="docMainWrapper wrapper"><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">Tran [...]
<p>Kafka Source Connector 用于从 Kafka 的主题中拉取消息并持久化到 Pulsar 主题中。</p>
-<h3><a class="anchor" aria-hidden="true"
id="source-configuration-options"></a><a href="#source-configuration-options"
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 [...]
+<h3><a class="anchor" aria-hidden="true" id="source-配置选项"></a><a
href="#source-配置选项" 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
[...]
<table>
<thead>
-<tr><th>Name</th><th>Required</th><th>默认值</th><th>说明：</th></tr>
+<tr><th>Name</th><th>Required</th><th>Default</th><th>Description</th></tr>
</thead>
<tbody>
<tr><td>bootstrapServers</td><td><code>true</code></td><td><code>null</code></td><td>用于建立与
Kafka 集群初始连接的主机/端口对列表。</td></tr>
<tr><td>groupId</td><td><code>true</code></td><td><code>null</code></td><td>用于标识消费者所属消费者组的唯一字符串。</td></tr>
<tr><td>fetchMinBytes</td><td><code>false</code></td><td><code>1</code></td><td>每次获取响应所需的最小字节数。</td></tr>
<tr><td>autoCommitEnabled</td><td><code>false</code></td><td><code>true</code></td><td>如果设置为
true，消费者的偏移量会在后台定期提交。如果处理失败，新的消费者将使用已提交的偏移量作为消费开始的位置。</td></tr>
-<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>消费者偏移量自动提交的频率（以毫秒为单位）如果<code>autoCommitEnabled</code>
设置为 true</td></tr>
-<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 的组管理设备时，心跳与消费者之间的间隔。</td></tr>
-<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>The
timeout used to detect consumer failures when using Kafka's group management
facility.</td></tr>
+<tr><td>autoCommitIntervalMs</td><td><code>false</code></td><td><code>5000</code></td><td>如果
<code>autoCommitEnabled</code> 设置为 true，消费者偏移量自动提交的频率，以毫秒为单位。</td></tr>
+<tr><td>heartbeatIntervalMs</td><td><code>false</code></td><td><code>3000</code></td><td>使用
Kafka 组管理设施时，心跳与消费者之间的时间间隔。</td></tr>
+<tr><td>sessionTimeoutMs</td><td><code>false</code></td><td><code>30000</code></td><td>使用
Kafka 组管理设施时，检测消费者故障的超时。</td></tr>
<tr><td>topic</td><td><code>true</code></td><td><code>null</code></td><td>用于接收
Kafka 记录的主题名称。</td></tr>
<tr><td>consumerConfigProperties</td><td><code>false</code></td><td><code>null</code></td><td>要传递给
Consumer 的消费者配置属性。 请注意，connector 配置文件中指定的其他属性优先于此配置</td></tr>
<tr><td>keyDeserializationClass</td><td><code>false</code></td><td><code>valueDeserializationClass</code></td><td>Key的实现了
org.apache.kafka.common.serialization.Deserializer 接口的反序列化类。</td></tr>
@@ -59,7 +59,7 @@
<tr><td>valueSerializerClass</td><td><code>false</code></td><td><code>org.apache.kafka.common.serialization.ByteArraySerializer</code></td><td>Serializer
class for value that implements the
org.apache.kafka.common.serialization.Serializer interface.</td></tr>
</tbody>
</table>
-</span></div></article></div><div class="docs-prevnext"></div></div></div><nav
class="onPageNav"><ul class="toc-headings"><li><a href="#source">Source</a><ul
class="toc-headings"><li><a href="#source-configuration-options">Source
Configuration Options</a></li></ul></li><li><a href="#sink">Sink</a><ul
class="toc-headings"><li><a href="#sink-configuration-options">Sink
Configuration Options</a></li></ul></li></ul></nav></div><footer
class="nav-footer" id="footer"><section class="copyright" [...]
+</span></div></article></div><div class="docs-prevnext"></div></div></div><nav
class="onPageNav"><ul class="toc-headings"><li><a href="#source">Source</a><ul
class="toc-headings"><li><a href="#source-配置选项">Source
配置选项</a></li></ul></li><li><a href="#sink">Sink</a><ul
class="toc-headings"><li><a href="#sink-configuration-options">Sink
Configuration Options</a></li></ul></li></ul></nav></div><footer
class="nav-footer" id="footer"><section class="copyright">Copyright © 2019 The
Apache Softw [...]
const community =
document.querySelector("a[href='#community']").parentNode;
const communityMenu =
'<li>' +
diff --git a/content/swagger/2.5.0-SNAPSHOT/swagger.json
b/content/swagger/2.5.0-SNAPSHOT/swagger.json
index 1d7ab15..cd05aad 100644
--- a/content/swagger/2.5.0-SNAPSHOT/swagger.json
+++ b/content/swagger/2.5.0-SNAPSHOT/swagger.json
@@ -4303,6 +4303,13 @@
"required" : true,
"type" : "string"
}, {
+ "name" : "perPartition",
+ "in" : "query",
+ "description" : "Get per partition stats",
+ "required" : false,
+ "type" : "boolean",
+ "default" : true
+ }, {
"name" : "authoritative",
"in" : "query",
"description" : "Is authentication required to perform this
operation",
@@ -6298,6 +6305,13 @@
"required" : true,
"type" : "string"
}, {
+ "name" : "perPartition",
+ "in" : "query",
+ "description" : "Get per partition stats",
+ "required" : false,
+ "type" : "boolean",
+ "default" : true
+ }, {
"name" : "authoritative",
"in" : "query",
"description" : "Is authentication required to perform this
operation",
@@ -8638,11 +8652,9 @@
"type" : "number",
"format" : "double"
},
- "overLoaded" : {
- "type" : "boolean"
- },
- "loadReportType" : {
- "type" : "string"
+ "lastUpdate" : {
+ "type" : "integer",
+ "format" : "int64"
},
"msgThroughputIn" : {
"type" : "number",
@@ -8652,8 +8664,8 @@
"type" : "number",
"format" : "double"
},
- "underLoaded" : {
- "type" : "boolean"
+ "cpu" : {
+ "$ref" : "#/definitions/ResourceUsage"
},
"memory" : {
"$ref" : "#/definitions/ResourceUsage"
@@ -8667,12 +8679,14 @@
"bandwidthOut" : {
"$ref" : "#/definitions/ResourceUsage"
},
- "lastUpdate" : {
- "type" : "integer",
- "format" : "int64"
+ "overLoaded" : {
+ "type" : "boolean"
},
- "cpu" : {
- "$ref" : "#/definitions/ResourceUsage"
+ "underLoaded" : {
+ "type" : "boolean"
+ },
+ "loadReportType" : {
+ "type" : "string"
}
}
},
@@ -8831,10 +8845,10 @@
"type" : "number",
"format" : "double"
},
- "producerName" : {
+ "connectedSince" : {
"type" : "string"
},
- "connectedSince" : {
+ "producerName" : {
"type" : "string"
},
"clientVersion" : {
@@ -9502,10 +9516,10 @@
"type" : "string"
}
},
- "producerName" : {
+ "connectedSince" : {
"type" : "string"
},
- "connectedSince" : {
+ "producerName" : {
"type" : "string"
},
"clientVersion" : {
diff --git a/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
b/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
index b16a0e8..e147804 100644
--- a/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
+++ b/content/swagger/2.5.0-SNAPSHOT/swaggerfunctions.json
@@ -1355,20 +1355,6 @@
"type" : "integer",
"format" : "int64"
},
- "orderingKey" : {
- "type" : "array",
- "items" : {
- "type" : "string",
- "format" : "byte"
- }
- },
- "encryptionCtx" : {
- "$ref" : "#/definitions/EncryptionContext"
- },
- "redeliveryCount" : {
- "type" : "integer",
- "format" : "int32"
- },
"schemaVersion" : {
"type" : "array",
"items" : {
@@ -1393,6 +1379,20 @@
"replicatedFrom" : {
"type" : "string"
},
+ "orderingKey" : {
+ "type" : "array",
+ "items" : {
+ "type" : "string",
+ "format" : "byte"
+ }
+ },
+ "encryptionCtx" : {
+ "$ref" : "#/definitions/EncryptionContext"
+ },
+ "redeliveryCount" : {
+ "type" : "integer",
+ "format" : "int32"
+ },
"producerName" : {
"type" : "string"
},
