1,启动kafka自带的zookeeper
./zookeeper-server-start.sh ../config/zookeeper.properties 1>/dev/null 2>&1 &
1>/dev/null 将输出定位到一个空的位置
2>&1 错误输出同 1一样定位到空位置
&:最后这个&符号指在后台输出
2,启动kafka服务
bin/kafka-server-start.sh config/server.properties
3,生产者
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic order_name
4,消费者
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic order_name --from-beginning
时间: 2024-10-06 00:07:24