Producer Sample Commissioning

Prerequisites

• Ensure that Windows is configured to allow Kafka access through an EIP if you need to debug applications on Windows. For details, see Kafka Access Configuration on Windows Using EIPs.
• Ensure that the current user has the read permission on all files in the src/main/resources directory and the dependent library file directory if you need to debug applications on Linux. Ensure that the JDK has been installed and Java environment variables have been set.

Commissioning Applications on Windows

1. Ensure that the mappings between the host names and service IP addresses of all the hosts in the remote cluster are configured in the local hosts file.
2. Run Producer.java on IntelliJ IDEA, as shown in Figure 1.
   Figure 1 Running Producer.java.
   

3. Check the displayed console window and you can find that Producer is sending messages to the default topic (example-metric1). One piece of log is printed when every 10 messages are sent.
   Figure 2 Producer running window
   

Commissioning Applications on Linux

1. Export a JAR package.

   You can build a JAR file in either of the following ways:

   • Method 1:

     Choose Maven > Sample projectname > Lifecycle > clean, double click clean to run the clean command of Maven.

     Choose Maven > Sample project name > Lifecycle > install, double click install to run the install command of Maven.

     Figure 3 Maven tools: clean and installl
     
   • Method 2: Go to the directory where the pom.xml file is located in the Terminal window in the lower part of the IDEA, and run the mvn clean install command to compile the pom.xml file.
     Figure 4 Enter mvn clean compile in the IDEA Terminal text box.
     

     After the compilation is completed, the message "Build Success" is displayed, the target directory is generated, and the generated JAR file is stored in the target directory.

     Figure 5 When the compilation is completed, the JAR file is generated.
     

2. Copy the JAR file generated during project compilation to the /opt/hadoopclient/lib directory.
3. Copy all files in the src/main/resources directory of the IntelliJ IDEA project to the src/main/resources directory at the same level as the lib folder, that is, /opt/client/src/main/resources. /opt/client indicates the client installation path. Replace it with the actual one.
4. Ensure that the current user has read permission of all the files in the src/main/resources and lib folders in /opt/client, jdk has been installed,and java environment variables are set. Then, run the command to run the example project, for example:

   java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example.Producer