tencent cloud

Feedback

Running Kafka Client (Optional)

Last updated: 2024-01-09 14:45:02

Overview

This document explains how to start using Kafka APIs after you purchase the CKafka service. After setting up a CKafka environment on a CVM instance, you need to 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.

Step 2. Download the Kafka installation file.

Download and decompress the Kafka installation file.

Step 3. Test Kafka APIs.

Go to the ./bin directory, and produce and consume a message via CLI commands.
1. Open a terminal window to start a consumer.
bash kafka-console-consumer.sh --bootstrap-server XXXX:port --topic XXXX --consumer.config ../config/consumer.properties
Note:
Replace XXXX:port with the domain name and port for VPC 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. Open another terminal window to start a producer.
bash kafka-console-producer.sh --broker-list XXXX:port --topic XXXX --producer.config ../config/producer.properties
Note:
Replace XXXX:port with the domain name and port for VPC 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.

The details of the message are as follows:


Contact Us

Contact our sales team or business advisors to help your business.

Technical Support

Open a ticket if you're looking for further assistance. Our Ticket is 7x24 avaliable.

7x24 Phone Support