pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From si...@apache.org
Subject [pulsar] branch master updated: Amend several typos in Kafka Wrapper doc. (#3387)
Date Sun, 20 Jan 2019 03:08:35 GMT
This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new f669d7d  Amend several typos in Kafka Wrapper doc. (#3387)
f669d7d is described below

commit f669d7d254383489d4d23c123b2410026b076457
Author: Fangbin Sun <sunfangbin@gmail.com>
AuthorDate: Sun Jan 20 11:08:29 2019 +0800

    Amend several typos in Kafka Wrapper doc. (#3387)
    
    ### Motivation
    Kafka Wrapper doc minor improvement.
    
    ### Modifications
    Amend several typos in Kafka Wrapper.
---
 site2/docs/adaptors-kafka.md | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/site2/docs/adaptors-kafka.md b/site2/docs/adaptors-kafka.md
index 49ef3f3..e177726 100644
--- a/site2/docs/adaptors-kafka.md
+++ b/site2/docs/adaptors-kafka.md
@@ -9,12 +9,12 @@ Pulsar provides an easy option for applications that are currently written
using
 
 ## Using the Pulsar Kafka compatibility wrapper
 
-In an existing application, change the regular Kafka client dependency and replace it with
the Pulsar Kafka wrapper. Remove:
+In an existing application, change the regular Kafka client dependency and replace it with
the Pulsar Kafka wrapper. Remove the following dependency in `pom.xml`:
 
 ```xml
 <dependency>
   <groupId>org.apache.kafka</groupId>
-  <artifactId>kakfa-clients</artifactId>
+  <artifactId>kafka-clients</artifactId>
   <version>0.10.2.1</version>
 </dependency>
 ```
@@ -48,7 +48,7 @@ unshaded pulsar kafka client wrapper.
 </dependency>
 ```
 
-When using this dependency, you need to construct producer using `org.apache.kafka.clients.producer.PulsarKafkaProducer`
+When using this dependency, you need to construct producers using `org.apache.kafka.clients.producer.PulsarKafkaProducer`
 instead of `org.apache.kafka.clients.producer.KafkaProducer` and `org.apache.kafka.clients.producer.PulsarKafkaConsumer`
for consumers.
 
 ## Producer example
@@ -246,7 +246,7 @@ You can configure Pulsar authentication provider directly from the Kafka
propert
 |:---------------------------------------|:--------|:---------------------------------------------------------------------------------------|
 | [`pulsar.producer.name`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setProducerName-java.lang.String-)
| | Specify producer name |
 | [`pulsar.producer.initial.sequence.id`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setInitialSequenceId-long-)
|  | Specify baseline for sequence id for this producer |
-| [`pulsar.producer.max.pending.messages`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setMaxPendingMessages-int-)
| `1000` | Set the max size of the queue holding the messages pending to receive an acknowledgment
from the broker.  |
+| [`pulsar.producer.max.pending.messages`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setMaxPendingMessages-int-)
| `1000` | Set the max size of the queue holding the messages pending to receive an acknowledgment
from the broker  |
 | [`pulsar.producer.max.pending.messages.across.partitions`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setMaxPendingMessagesAcrossPartitions-int-)
| `50000` | Set the number of max pending messages across all the partitions  |
 | [`pulsar.producer.batching.enabled`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setBatchingEnabled-boolean-)
| `true` | Control whether automatic batching of messages is enabled for the producer |
 | [`pulsar.producer.batching.max.messages`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerConfiguration.html#setBatchingMaxMessages-int-)
| `1000` | The maximum number of messages permitted in a batch |
@@ -257,6 +257,6 @@ You can configure Pulsar authentication provider directly from the Kafka
propert
 | Config property                        | Default | Notes                              
                                                   |
 |:---------------------------------------|:--------|:---------------------------------------------------------------------------------------|
 | [`pulsar.consumer.name`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setConsumerName-java.lang.String-)
| | Set the consumer name |
-| [`pulsar.consumer.receiver.queue.size`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setReceiverQueueSize-int-)
| 1000 | Sets the size of the consumer receive queue |
-| [`pulsar.consumer.total.receiver.queue.size.across.partitions`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setMaxTotalReceiverQueueSizeAcrossPartitions-int-)
| 50000 | Set the max total receiver queue size across partitons |
+| [`pulsar.consumer.receiver.queue.size`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setReceiverQueueSize-int-)
| 1000 | Set the size of the consumer receiver queue |
+| [`pulsar.consumer.total.receiver.queue.size.across.partitions`](http://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ConsumerConfiguration.html#setMaxTotalReceiverQueueSizeAcrossPartitions-int-)
| 50000 | Set the max total receiver queue size across partitions |
 


Mime
View raw message