Replaced text Kafka 2.4 to 3.2

Author: Sreekanth Iyer (Ushta Te Consultancy Services)

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

@@ -34,10 +34,10 @@ For more information, refer
 
 ## 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
 
 

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>