【华为云Kafka全景实践课】day2 Kafka生产机制与实践实操手册

今天大致讲得是生产者的故事，老师给出的demo还是很值得学习的，不仅仅是Kafka，对消息队列而言，入栈需谨慎。

附件上是demo的zip包（便于解压），有需要的朋友可以获取。

接day1，我们在搭建好Kafka和Java环境后，然后执行程序来调用Kafka进行生产呢？

我们切换到Kafka的libs目录，发现并没有我们的demo，需要上传

上传demo

scp dms.kafka.demo.jar.zip root@{您的ECS虚拟机公网IP}:~

ssh登录您的ECS虚拟机

解压demo

unzip dms.kafka.demo.jar.zip

移动demo至指定路径

mv dms.kafka.demo.jar /root/kafka_2.12-1.1.0/libs

切换目录至目标路径

cd /root/kafka_2.12-1.1.0

⚠️务必注意是libs的上一层目录，这里手册中并没有重点说明，因为执行的命令是进了lib目录了的

执行命令:

利用demo进行生产

java -cp .:./libs/* dms.kafka.demo.KafkaProducerDemo {您的kafka broker地址} {生产消息的topic(之前创建的名称)}

执行消费脚本

依然在当前目录，即

/root/kafka_2.12-1.1.0 目录

执行命令:

借助kafka脚本进行消费


bin/kafka-console-consumer.sh --bootstrap-server {您的kafka broker地址} --topic {生产消息的topic(之前创建的名称)} --group test_grp --consumer-property enable.auto.commit=true --from-beginning