This document explains how to start using Kafka APIs after you purchase the CKafka service. You can download and decompress the Kafka installation file and perform simple testing on Kafka APIs.
Directions
Step 1. Install a JDK.
1. Check Java installation.
Open a terminal window and run this command:
java -version
If the output of the command is a Java version number, then Java is already installed in your system. If you have not installed Java yet, download and install a Java Development Kit (JDK).
2. Set up the Java environment.
Set the JAVA_HOME environment variable and point it to the Java installation directory on your machine.
For example, if you use Java JDK 1.8.0_20, the outputs on different operating systems are as follows:
Supported Operating Systems
Output
Windows
Set the environment variable JAVA_HOME to
C:\\Program Files\\Java\\jdkjdk1.8.0_20
Linux
export JAVA_HOME=/usr/local/java-current
Mac OSX
export JAVA_HOME=/Library/Java/Home
Add the Java compiler path to the system path:
Supported Operating Systems
Output
Windows
Add C:\\Program Files\\Java\\jdk1.8.0_20\\bin to the end of the system variable Path
Linux
export PATH=$PATH:$JAVA_HOME/bin/
Mac OSX
not required
Use the java -version command to check your Java installation.
Set username to a value in the format of instance ID + # + configured username, and password to a configured password.
1.3 In the ./bin directory of the installation file, add the statement of the full path of the JAAS file at the beginning of kafka-console-producer.sh and kafka-console-consumer.sh.
broker-list: replace XXXX:port with the domain name and port for public network access, which can be obtained in the Access Mode section on the Instance Details page in the console.
topic: replace XXXX with the topic name, which can be obtained on the Topic Management page in the console.
2.2 Open another terminal window to start a producer.
broker-list: replace XXXX:port with the domain name and port for public network access, which can be obtained in the Access Mode section on the Instance Details page in the console.
topic: replace XXXX with the topic name, which can be obtained on the Topic Management page in the console.
Enter the content of the message and press Enter.
Producing a message:
Consuming a message:
3. In the message querying page of the CKafka console, query the message sent.
Yes
No
Was this page helpful?