pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mme...@apache.org
Subject [pulsar] branch asf-site updated: Updated site at revision b424fad
Date Fri, 08 Feb 2019 09:04:29 GMT
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 a625a55  Updated site at revision b424fad
a625a55 is described below

commit a625a55551ded3876a1ae5c3b0ff8cf73190195a
Author: jenkins <builds@apache.org>
AuthorDate: Fri Feb 8 09:04:21 2019 +0000

    Updated site at revision b424fad
---
 content/docs/en/next/adaptors-kafka.html          |  6 +--
 content/docs/en/next/adaptors-kafka/index.html    |  6 +--
 content/docs/fr/next/adaptors-kafka.html          |  6 +--
 content/docs/fr/next/adaptors-kafka/index.html    |  6 +--
 content/docs/ja/next/adaptors-kafka.html          |  6 +--
 content/docs/ja/next/adaptors-kafka/index.html    |  6 +--
 content/docs/zh-CN/next/adaptors-kafka.html       |  6 +--
 content/docs/zh-CN/next/adaptors-kafka/index.html |  6 +--
 content/swagger/swagger.json                      | 58 +++++++++++------------
 9 files changed, 53 insertions(+), 53 deletions(-)

diff --git a/content/docs/en/next/adaptors-kafka.html b/content/docs/en/next/adaptors-kafka.html
index 78c1287..ab2c974 100644
--- a/content/docs/en/next/adaptors-kafka.html
+++ b/content/docs/en/next/adaptors-kafka.html
@@ -158,7 +158,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -174,7 +174,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -191,7 +191,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</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 78c1287..ab2c974 100644
--- a/content/docs/en/next/adaptors-kafka/index.html
+++ b/content/docs/en/next/adaptors-kafka/index.html
@@ -158,7 +158,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -174,7 +174,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -191,7 +191,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</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 a6fa2e5..2de88f7 100644
--- a/content/docs/fr/next/adaptors-kafka.html
+++ b/content/docs/fr/next/adaptors-kafka.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</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/index.html b/content/docs/fr/next/adaptors-kafka/index.html
index a6fa2e5..2de88f7 100644
--- a/content/docs/fr/next/adaptors-kafka/index.html
+++ b/content/docs/fr/next/adaptors-kafka/index.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</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.html b/content/docs/ja/next/adaptors-kafka.html
index feb17ee..d1c461f 100644
--- a/content/docs/ja/next/adaptors-kafka.html
+++ b/content/docs/ja/next/adaptors-kafka.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</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 feb17ee..d1c461f 100644
--- a/content/docs/ja/next/adaptors-kafka/index.html
+++ b/content/docs/ja/next/adaptors-kafka/index.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer Method</th><th style="text-align:left">Supported</th><th
style="text-align:left">Notes</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">Currently no support for explicitly set the partition id when publishing</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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 give error</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">Needs to point
to a single Pulsar service URL</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/docs/zh-CN/next/adaptors-kafka.html b/content/docs/zh-CN/next/adaptors-kafka.html
index b981a5a..0e10184 100644
--- a/content/docs/zh-CN/next/adaptors-kafka.html
+++ b/content/docs/zh-CN/next/adaptors-kafka.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer 方法</th><th style="text-align:left">支持</th><th
style="text-align:left">备注</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">目前不支持在发布时显式设置分区ID</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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">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">指定一个pulsar服务地址</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</code></td><td
style="text-align:left">Ignored</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 b981a5a..0e10184 100644
--- a/content/docs/zh-CN/next/adaptors-kafka/index.html
+++ b/content/docs/zh-CN/next/adaptors-kafka/index.html
@@ -151,7 +151,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><th style="text-align:left">Producer 方法</th><th style="text-align:left">支持</th><th
style="text-align:left">备注</th></tr>
 </thead>
 <tbody>
-<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left">目前不支持在发布时显式设置分区ID</td></tr>
+<tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record)</code></td><td style="text-align:left">Yes</td><td
style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>Future&lt;RecordMetadata&gt;
send(ProducerRecord&lt;K, V&gt; record, Callback callback)</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>void flush()</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>List&lt;PartitionInfo&gt;
partitionsFor(String topic)</code></td><td style="text-align:left">No</td><td
style="text-align:left"></td></tr>
@@ -167,7 +167,7 @@ consumer.subscribe(Arrays.asList(topic));
 </thead>
 <tbody>
 <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 'latest' if user does not give specific setting.</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">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">指定一个pulsar服务地址</td></tr>
@@ -184,7 +184,7 @@ consumer.subscribe(Arrays.asList(topic));
 <tr><td style="text-align:left"><code>metric.reporters</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.num.samples</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>metrics.sample.window.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
-<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
+<tr><td style="text-align:left"><code>partitioner.class</code></td><td
style="text-align:left">Yes</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>receive.buffer.bytes</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>reconnect.backoff.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
 <tr><td style="text-align:left"><code>request.timeout.ms</code></td><td
style="text-align:left">Ignored</td><td style="text-align:left"></td></tr>
diff --git a/content/swagger/swagger.json b/content/swagger/swagger.json
index 5dad7d7..6ddec5d 100644
--- a/content/swagger/swagger.json
+++ b/content/swagger/swagger.json
@@ -3974,7 +3974,7 @@
           "200" : {
             "description" : "successful operation",
             "schema" : {
-              "$ref" : "#/definitions/TopicStats"
+              "$ref" : "#/definitions/NonPersistentTopicStats"
             }
           },
           "403" : {
@@ -6987,41 +6987,41 @@
           "type" : "number",
           "format" : "double"
         },
-        "cpu" : {
-          "$ref" : "#/definitions/ResourceUsage"
-        },
-        "directMemory" : {
-          "$ref" : "#/definitions/ResourceUsage"
-        },
         "overLoaded" : {
           "type" : "boolean"
         },
+        "loadReportType" : {
+          "type" : "string"
+        },
         "underLoaded" : {
           "type" : "boolean"
         },
+        "bandwidthIn" : {
+          "$ref" : "#/definitions/ResourceUsage"
+        },
+        "bandwidthOut" : {
+          "$ref" : "#/definitions/ResourceUsage"
+        },
+        "memory" : {
+          "$ref" : "#/definitions/ResourceUsage"
+        },
+        "directMemory" : {
+          "$ref" : "#/definitions/ResourceUsage"
+        },
         "lastUpdate" : {
           "type" : "integer",
           "format" : "int64"
         },
-        "msgThroughputIn" : {
-          "type" : "number",
-          "format" : "double"
-        },
         "msgThroughputOut" : {
           "type" : "number",
           "format" : "double"
         },
-        "loadReportType" : {
-          "type" : "string"
-        },
-        "bandwidthIn" : {
-          "$ref" : "#/definitions/ResourceUsage"
-        },
-        "bandwidthOut" : {
+        "cpu" : {
           "$ref" : "#/definitions/ResourceUsage"
         },
-        "memory" : {
-          "$ref" : "#/definitions/ResourceUsage"
+        "msgThroughputIn" : {
+          "type" : "number",
+          "format" : "double"
         }
       }
     },
@@ -7181,13 +7181,13 @@
           "type" : "number",
           "format" : "double"
         },
-        "connectedSince" : {
+        "producerName" : {
           "type" : "string"
         },
-        "clientVersion" : {
+        "connectedSince" : {
           "type" : "string"
         },
-        "producerName" : {
+        "clientVersion" : {
           "type" : "string"
         },
         "address" : {
@@ -7895,13 +7895,13 @@
             "type" : "string"
           }
         },
-        "connectedSince" : {
+        "producerName" : {
           "type" : "string"
         },
-        "clientVersion" : {
+        "connectedSince" : {
           "type" : "string"
         },
-        "producerName" : {
+        "clientVersion" : {
           "type" : "string"
         },
         "address" : {
@@ -8003,11 +8003,11 @@
     "ResourceUnit" : {
       "type" : "object",
       "properties" : {
-        "resourceId" : {
-          "type" : "string"
-        },
         "availableResource" : {
           "$ref" : "#/definitions/ResourceDescription"
+        },
+        "resourceId" : {
+          "type" : "string"
         }
       }
     },


Mime
View raw message