Huanli-Meng commented on code in PR #15495:
URL: https://github.com/apache/pulsar/pull/15495#discussion_r869015786
##########
site2/website/versioned_docs/version-2.10.0/io-kafka-source.md:
##########
@@ -184,18 +163,49 @@ Here is an example of using the Kafka source connector
with the configuration fi
--parallelism 1
```
-10. Open a new terminal window and run the consumer.
+7. Open a new terminal window and run the Kafka producer locally.
```bash
- $ docker exec -it pulsar-kafka-standalone /bin/bash
+ python3 kafka-producer.py
+ ```
- $ pip install kafka-python
+8. Open a new terminal window and run the Pulsar consumer locally.
- $ python3 kafka-producer.py
+ ```bash
+ python3 pulsar-client.py
```
- The following information appears on the consumer terminal window.
+The following information appears on the consumer terminal window.
```bash
Received message: 'hello world'
```
+
+### On-premises cluster
+
+This example explains how to create a Kafka source connector in an on-premises
cluster.
+
+1. Copy the NAR package of the Kafka connector to the Pulsar connectors
directory.
+
+ ```
+ cp pulsar-io-kafka-{{connector:version}}.nar
$PULSAR_HOME/connectors/pulsar-io-kafka-{{connector:version}}.nar
+ ```
+
+2. Reload all [built-in
connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
+
+ ```
+ PULSAR_HOME/bin/pulsar-admin sources reload
+ ```
+
+3. Check whether the Kafka source connector is available on the list or not.
+
+ ```
+ PULSAR_HOME/bin/pulsar-admin sources available-sources
+ ```
+
+4. Create a Kafka source connector on a Pulsar cluster using the
[`pulsar-admin sources
create`](http://pulsar.apache.org/tools/pulsar-admin/2.8.0-SNAPSHOT/#-em-create-em--14)
command.
Review Comment:
Good point. Have fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
