fix

apache · May 18, 2023 · bb6b61d · bb6b61d
1 parent 98e849c
commit bb6b61d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/docs/en/connector-v2/sink/Kafka.md b/docs/en/connector-v2/sink/Kafka.md
@@ -97,7 +97,7 @@ This function by `MessageContentPartitioner` class implements `org.apache.kafka.
 
 > This example defines a SeaTunnel synchronization task that automatically generates data through FakeSource and sends it to Kafka Sink. FakeSource generates a total of 16 rows of data (row.num=16), with each row having two fields, name (string type) and age (int type). The final target topic is test_topic will also be 16 rows of data in the topic. And if you have not yet installed and deployed SeaTunnel, you need to follow the instructions in [Install SeaTunnel](../../start-v2/locally/deployment.md) to install and deploy SeaTunnel. And then follow the instructions in [Quick Start With SeaTunnel Engine](../../start-v2/locally/quick-start-seatunnel-engine.md) to run this job.
 
-```
+```hocon
 # Defining the runtime environment
 env {
   # You can set flink configuration here
@@ -140,7 +140,7 @@ sink {
 
 Replace the following `${username}` and `${password}` with the configuration values in AWS MSK.
 
-```
+```hocon
 sink {
   kafka {
       topic = "seatunnel"
@@ -164,7 +164,7 @@ Download `aws-msk-iam-auth-1.1.5.jar` from https://github.com/aws/aws-msk-iam-au
 
 Please ensure the IAM policy have `"kafka-cluster:Connect",`. Like this:
 
-```
+```hocon
 "Effect": "Allow",
 "Action": [
     "kafka-cluster:Connect",
@@ -175,7 +175,7 @@ Please ensure the IAM policy have `"kafka-cluster:Connect",`. Like this:
 
 Sink Config
 
-```
+```hocon
 sink {
   kafka {
       topic = "seatunnel"

diff --git a/docs/en/connector-v2/source/Kafka.md b/docs/en/connector-v2/source/Kafka.md
@@ -34,7 +34,7 @@ They can be downloaded via install-plugin.sh or from the Maven central repositor
 
 |                Name                 |                                    Type                                     | Required |         Default          |                                                                                                                                                        Description                                                                                                                                                         |
 |-------------------------------------|-----------------------------------------------------------------------------|----------|--------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| topic                               | String                                                                      | yes      | -                        | Topic name(s) to read data from when the table is used as source. It also supports topic list for source by separating topic by semicolon like 'topic-1,topic-2'.                                                                                                                                                          |
+| topic                               | String                                                                      | yes      | -                        | Topic name(s) to read data from when the table is used as source. It also supports topic list for source by separating topic by comma like 'topic-1,topic-2'.                                                                                                                                                              |
 | bootstrap.servers                   | String                                                                      | yes      | -                        | Comma separated list of Kafka brokers.                                                                                                                                                                                                                                                                                     |
 | pattern                             | Boolean                                                                     | no       | false                    | If `pattern` is set to `true`,the regular expression for a pattern of topic names to read from. All topics in clients with names that match the specified regular expression will be subscribed by the consumer.                                                                                                           |
 | consumer.group                      | String                                                                      | no       | SeaTunnel-Consumer-Group | `Kafka consumer group id`, used to distinguish different consumer groups.                                                                                                                                                                                                                                                  |
@@ -53,7 +53,7 @@ They can be downloaded via install-plugin.sh or from the Maven central repositor
 
 ### Simple
 
-> This example reads the data of kafka's topic_1, topic_2, topic_3 and prints it to the client.
+> This example reads the data of kafka's topic_1, topic_2, topic_3 and prints it to the client.And if you have not yet installed and deployed SeaTunnel, you need to follow the instructions in Install SeaTunnel to install and deploy SeaTunnel. And if you have not yet installed and deployed SeaTunnel, you need to follow the instructions in [Install SeaTunnel](../../start-v2/locally/deployment.md) to install and deploy SeaTunnel. And then follow the instructions in [Quick Start With SeaTunnel Engine](../../start-v2/locally/quick-start-seatunnel-engine.md) to run this job.
 
 ```hocon
 # Defining the runtime environment