Tag: Apache Kafka

Apache Kafka – Develop Producer Java application No.66

Posted on by kumoman

How to develop Producer application by Java on Visual Studio Code is shown in this blog. ▼1. Apache Kafka Ref: Apache Kafka ▼2. Prerequisites Install Apache Kafka 4 nodes No.42 Apache Kafka Word Count – Java No.44“2-3. Installing Apache Maven” ▼3. Develop Producer Java application This producer Java application write events from 1 to 100 into a topic. 3-1. Make a directoryMake a directory to develop an application. 3-2. Create a project using Apache Maven 3-3. Remove the App.java and AppTest.java files 3-4. Update pom.xml file Adding below in pom.xml(a part of pom.xml) Dependency Analytics Extension need to be installed on VS Code to check and update dependencies automatically. 3-5. … Continue reading “Apache Kafka – Develop Producer Java application No.66”

Apache Kafka Word Count – Java No.44

Posted on by kumoman

How to count the words in topic by Java is shown. ▼1. Steps of counting words in a topic by Java ▼2. Prerequisites 2-1. Installing an Apache Kafka cluster Install Apache Kafka 4 nodes No.42 2-2. Installing IntelliJ IDEA Install IntelliJ IDEA on Ubuntu No.43 2-3. Installing Apache Maven Maven – Download Apache Maven 2-4. Setting parameters of $KAFKABROKERS and $KAFKAZOOKEEPER 2-5. Creating the topic for both input and output ▼3. Counting words in a topic by Java 3-1. Creating a project of IntelliJ IDEA Creating a new project 3-2. Confirming the version 1.8 of JDK is used 3-3. Putting the following information while creating a project 3-4. Updating pom.xml … Continue reading “Apache Kafka Word Count – Java No.44”

Install Apache Kafka 4 nodes No.42

Posted on by kumoman

How to install Apache Kafka 4 nodes is shown here. 4 ubuntu nodes are used for Apache Kafka. ▼1. What is Apache Kafka? Kafka combines three key capabilities. Ref: Apache Kafka ▼2. Installing Apache Kafka with 4 nodes 2-1. Preparing for 4 Ubuntu 20.04.01 LTS x64 nodes One node is used for Zookeeper Server. other 3 nodes are used to provide Kafka Broker services. 2-2. Updating hosts file on 4 nodes 2-3. Installing Java 8 JDK on 4 nodes Azul Zulu OpenJDK Java 8 (LTS) is used for this Kafka. Download Azul Zulu Builds of OpenJDK | Azul 2-4. Installing Apache Kafka on 4 nodes There is a download site … Continue reading “Install Apache Kafka 4 nodes No.42”