Merge pull request #271170 from sreekzz/Change-Kafka-Version

Replaced text Kafka 2.4 to 3.2

Author: prmerger-automator[bot]

articles/hdinsight-aks/flink/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2.md

@@ -103,7 +103,7 @@ Flink provides an Apache Kafka connector for reading data from and writing data
 *abfsGen2.java*
 
 > [!Note]
-> Replace [Apache Kafka on HDInsight cluster](../../hdinsight/kafka/apache-kafka-get-started.md) bootStrapServers with your own brokers for Kafka 2.4 or 3.2
+> Replace [Apache Kafka on HDInsight cluster](../../hdinsight/kafka/apache-kafka-get-started.md) bootStrapServers with your own brokers for Kafka 3.2
 
 ``` java
 package contoso.example;

articles/hdinsight-aks/flink/change-data-capture-connectors-for-apache-flink.md

@@ -138,7 +138,7 @@ GO
 ```
 ##### Maven source code on IdeaJ
 
-In the below snippet, we use Kafka 2.4.1. Based on your usage, update the version of Kafka on `<kafka.version>`. 
+Based on your usage, update the version of Kafka on `<kafka.version>`. 
 
 **maven pom.xml**
 

articles/hdinsight-aks/flink/join-stream-kafka-table-filesystem.md

@@ -31,12 +31,6 @@ We're creating a topic called `user_events`.
   timestamp, 
   ```
 
-**Kafka 2.4.1**
-```
-/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --replication-factor 2 --partitions 3 --topic user_events --zookeeper zk0-contos:2181
-/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --replication-factor 2 --partitions 3 --topic user_events_output --zookeeper zk0-contos:2181
-```
-
 **Kafka 3.2.0**
 ```
 /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --replication-factor 2 --partitions 3 --topic user_events --bootstrap-server wn0-contsk:9092
@@ -84,7 +78,7 @@ In this step, we perform the following activities
         <flink.version>1.17.0</flink.version>
         <java.version>1.8</java.version>
         <scala.binary.version>2.12</scala.binary.version>
-        <kafka.version>3.2.0</kafka.version> //replace with 2.4.1 if you are using HDInsight Kafka 2.4.1
+        <kafka.version>3.2.0</kafka.version>
     </properties>
     <dependencies>
         <dependency>

articles/hdinsight-aks/flink/sink-kafka-to-kibana.md

@@ -1,9 +1,9 @@
 ---
 title: Use Elasticsearch along with Apache Flink® on HDInsight on AKS
-description: Learn how to use Elasticsearch along Apache Flink® on HDInsight on AKS
+description: Learn how to use Elasticsearch along Apache Flink® on HDInsight on AKS.
 ms.service: hdinsight-aks
 ms.topic: how-to
-ms.date: 10/27/2023
+ms.date: 04/04/2024
 ---
 
 # Using Elasticsearch with Apache Flink® on HDInsight on AKS
@@ -18,7 +18,8 @@ In this article, learn how to Use Elastic along Apache Flink® on HDInsight on A
 
 ## Elasticsearch and Kibana
 
-Elasticsearch is a distributed, free and open search and analytics engine for all types of data, including 
+Elasticsearch is a distributed, free, and open search and analytics engine for all types of data, including.
+
 * Textual
 * Numerical
 * Geospatial
@@ -27,17 +28,17 @@ Elasticsearch is a distributed, free and open search and analytics engine for al
 
 Kibana is a free and open frontend application that sits on top of the elastic stack, providing search and data visualization capabilities for data indexed in Elasticsearch.
 
-For more information, refer 
+For more information, see.
 * [Elasticsearch](https://www.elastic.co)
 * [Kibana](https://www.elastic.co/guide/en/kibana/current/index.html)
 
 
 ## Prerequisites
 
-* [Create Flink 1.16.0 cluster](./flink-create-cluster-portal.md) 
+* [Create Flink 1.17.0 cluster](./flink-create-cluster-portal.md) 
 * Elasticsearch-7.13.2 
 * Kibana-7.13.2 
-* [HDInsight 5.0 - Kafka 2.4.1](../../hdinsight/kafka/apache-kafka-get-started.md)
+* [HDInsight 5.0 - Kafka 3.2.0](../../hdinsight/kafka/apache-kafka-get-started.md)
 * IntelliJ IDEA for development on an Azure VM which in the same Vnet
 
 
@@ -90,7 +91,7 @@ sudo apt install elasticsearch
 
 For installing and configuring Kibana Dashboard, we don’t need to add any other repository because the packages are available through the already added ElasticSearch. 
 
-We use the following command to install Kibana
+We use the following command to install Kibana.
 
 ```
 sudo apt install kibana
@@ -111,9 +112,9 @@ sudo apt install kibana
     ```
 ### Access the Kibana Dashboard web interface
 
-In order to make Kibana accessible from output, need to set network.host to 0.0.0.0 
+In order to make Kibana accessible from output, need to set network.host to 0.0.0.0.
 
-configure /etc/kibana/kibana.yml  on Ubuntu VM
+Configure `/etc/kibana/kibana.yml`  on Ubuntu VM
 
 > [!NOTE]
 > 10.0.1.4 is a local private IP, that we have used which can be accessed in maven project develop Windows VM. You're required to make modifications according to your network security requirements. We use the same IP later to demo for performing analytics on Kibana.
@@ -129,12 +130,12 @@ elasticsearch.hosts: ["http://10.0.1.4:9200"]
 
 ## Prepare Click Events on HDInsight Kafka
 
-We use python output as input to produce the streaming data
+We use python output as input to produce the streaming data.
 
 ```
 sshuser@hn0-contsk:~$ python weblog.py | /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --bootstrap-server wn0-contsk:9092 --topic click_events
 ```
-Now, lets check messages in this topic
+Now, lets check messages in this topic.
 
 ```
 sshuser@hn0-contsk:~$ /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server wn0-contsk:9092 --topic click_events
@@ -149,7 +150,7 @@ sshuser@hn0-contsk:~$ /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.s
 
 ## Creating Kafka Sink to Elastic
 
-Let us write maven source code on the Windows VM
+Let us write maven source code on the Windows VM.
 
 **Main: kafkaSinkToElastic.java**
 ``` java
@@ -289,7 +290,7 @@ public class kafkaSinkToElastic {
 
 **Package the jar and submit to Flink to run on WebSSH**
 
-On [Secure Shell for Flink](./flink-web-ssh-on-portal-to-flink-sql.md), you can use the following commands
+On [Secure Shell for Flink](./flink-web-ssh-on-portal-to-flink-sql.md), you can use the following commands.
 
 ```
 msdata@pod-0 [ ~ ]$ ls -l FlinkElasticSearch-1.0-SNAPSHOT.jar 
@@ -329,7 +330,7 @@ Job has been submitted with JobID e0eba72d5143cea53bcf072335a4b1cb
 
 ## Validation on Apache Flink Job UI
 
-You can find the job in running state on your Flink Web UI
+You can find the job in running state on your Flink Web UI.
 
 :::image type="content" source="./media/sink-kafka-to-kibana/flink-elastic-job.png" alt-text="Screenshot showing Kibana UI to start Elasticsearch and Kibana and perform analytics on Kibana." lightbox="./media/sink-kafka-to-kibana/flink-elastic-job.png":::
 

articles/hdinsight-aks/flink/use-apache-nifi-with-datastream-api.md

@@ -31,12 +31,8 @@ By combining the low latency streaming features of Apache Flink and the dataflow
 For purposes of this demonstration, we're using a HDInsight Kafka Cluster. Let us prepare HDInsight Kafka topic for the demo.
 
 > [!NOTE]
-> Setup a HDInsight cluster with [Apache Kafka](../../hdinsight/kafka/apache-kafka-get-started.md) and replace broker list with your own list before you get started for both Kafka 2.4 and 3.2.
+> Setup a HDInsight cluster with [Apache Kafka](../../hdinsight/kafka/apache-kafka-get-started.md) and replace broker list with your own list before you get started for both Kafka 3.2.
 
-**Kafka 2.4.1**
-```
-/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --replication-factor 2 --partitions 3 --topic click_events --zookeeper zk0-contsk:2181
-```
 
 **Kafka 3.2.0**
 ```
@@ -182,7 +178,6 @@ public class ClickSource implements SourceFunction<Event> {
 ```
 **Maven pom.xml**
 
-You can replace 2.4.1 with 3.2.0 in case you're using Kafka 3.2.0 on HDInsight, where applicable on the pom.xml.
 
 ``` xml
 <?xml version="1.0" encoding="UTF-8"?>
@@ -200,7 +195,7 @@ You can replace 2.4.1 with 3.2.0 in case you're using Kafka 3.2.0 on HDInsight,
         <flink.version>1.17.0</flink.version>
         <java.version>1.8</java.version>
         <scala.binary.version>2.12</scala.binary.version>
-        <kafka.version>3.2.0</kafka.version>     ---> Replace 2.4.1 with 3.2.0 , in case you're using HDInsight Kafka 3.2.0
+        <kafka.version>3.2.0</kafka.version>
     </properties>
     <dependencies>
         <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java -->

articles/hdinsight-aks/flink/use-flink-to-sink-kafka-message-into-hbase.md

@@ -170,7 +170,7 @@ hbase:002:0>
         <java.version>1.8</java.version>
         <scala.binary.version>2.12</scala.binary.version>
         <hbase.version>2.4.11</hbase.version>
-        <kafka.version>3.2.0</kafka.version> // Replace with 2.4.0 for HDInsight Kafka 2.4
+        <kafka.version>3.2.0</kafka.version>
     </properties>
     <dependencies>
         <dependency>