After completing the configuration of instances, topics, and other resources in the console, you can also download and decompress the Kafka toolkit and perform simple message sending and receiving tests through the Kafka API.
Prerequisites
You have created the required TDMQ for CKafka (CKafka) resources.
You have completed the environment configuration by seeing Preparations.
username is in the format of instance ID + # + configured username, and password is the configured user password.
2.3 In the ./bin directory of the toolkit, add the JAAS file path declaration (using the full path) at the beginning of the kafka-console-producer.sh and kafka-console-consumer.sh files.
broker-list: Replace XXXX:port with the public network access domain name and port. You can obtain it in the Access Mode module on the instance details page in the console.
Topic: Replace XXXX with the topic name. You can obtain it from the Topic List page in the console.
3.2 Open another terminal window and start the producer.
broker-list: Replace XXXX:port with the public network access domain name and port. You can obtain it in the Access Mode module on the instance details page in the console.
Topic: Replace XXXX with the topic name. You can obtain it from the Topic List page in the console.
3.3 After you enter the message content and press Enter, the consumer receives the message almost simultaneously.
