Skip to content

Commit 03d5005

Browse files
authored
Improved Acrolinx Score
Improved Acrolinx Score
1 parent 2abacac commit 03d5005

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

articles/hdinsight-aks/flink/create-kafka-table-flink-kafka-sql-connector.md

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
---
22
title: How to create Apache Kafka table on an Apache Flink® on HDInsight on AKS
3-
description: Learn how to create Apache Kafka table on Apache Flink®
3+
description: Learn how to create Apache Kafka table on Apache Flink®.
44
ms.service: hdinsight-aks
55
ms.topic: how-to
66
ms.date: 03/14/2024
@@ -19,7 +19,7 @@ Using this example, learn how to Create Kafka table on Apache FlinkSQL.
1919

2020
## Kafka SQL connector on Apache Flink
2121

22-
The Kafka connector allows for reading data from and writing data into Kafka topics. For more information, refer [Apache Kafka SQL Connector](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka)
22+
The Kafka connector allows for reading data from and writing data into Kafka topics. For more information, refer [Apache Kafka SQL Connector](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka).
2323

2424
## Create a Kafka table on Flink SQL
2525

@@ -119,7 +119,7 @@ sshuser@hn0-contsk:~$ /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.s
119119

120120
### Apache Flink SQL client
121121

122-
Detailed instructions are provided on how to use Secure Shell for [Flink SQL client](./flink-web-ssh-on-portal-to-flink-sql.md)
122+
Detailed instructions are provided on how to use Secure Shell for [Flink SQL client](./flink-web-ssh-on-portal-to-flink-sql.md).
123123

124124
### Download Kafka SQL Connector & Dependencies into SSH
125125

@@ -131,7 +131,7 @@ wget https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka/1.17.
131131

132132
### Connect to Apache Flink SQL Client
133133

134-
Let's now connect to the Flink SQL Client with Kafka SQL client jars
134+
Let's now connect to the Flink SQL Client with Kafka SQL client jars.
135135
```
136136
msdata@pod-0 [ /opt/flink-webssh ]$ bin/sql-client.sh -j flink-connector-kafka-1.17.0.jar -j kafka-clients-3.2.0.jar
137137
```
@@ -163,18 +163,18 @@ select * from KafkaTable;
163163

164164
### Produce Kafka messages
165165

166-
Let's now produce Kafka messages to the same topic, using HDInsight Kafka
166+
Let's now produce Kafka messages to the same topic, using HDInsight Kafka.
167167
```
168168
python weblog.py | /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --bootstrap-server wn0-contsk:9092 --topic click_events
169169
```
170170

171171
### Table on Apache Flink SQL
172172

173-
You can monitor the table on Flink SQL
173+
You can monitor the table on Flink SQL.
174174

175175
:::image type="content" source="./media/create-kafka-table-flink-kafka-sql-connector/monitor-table-data-on-flink-sql.png" alt-text="Screenshot showing How to monitor table date on Flink SQL.":::
176176

177-
Here are the streaming jobs on Flink Web UI
177+
Here are the streaming jobs on Flink Web UI.
178178

179179
:::image type="content" source="./media/create-kafka-table-flink-kafka-sql-connector/flink-web-ui-kafka-jobs.png" alt-text="Screenshot showing jobs on the Flink web UI.":::
180180

0 commit comments

Comments
 (0)