本文一起来看下在Linux环境如何安装单机版的卡夫卡,用于测试之用,下面我们就开始吧!
2:下载和解压在这里 下载,然后tar -zxf 解压,如下是我本地的解压目录:
[root@localhost kafka]# pwd /usr/local/study/kafka [root@localhost kafka]# ls kafka_2.11-2.2.13:配置
修改server.properties,修改broker-id,以及日志目录:
broker.id=1 log.dir=/data/kafka/logs-14:启动 4.1:启动zk
/usr/local/study/kafka/kafka_2.11-2.2.1/bin/zookeeper-server-start.sh -daemon /usr/local/study/kafka/kafka_2.11-2.2.1/config/zookeeper.properties4.1:启动卡夫卡
/usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-server-start.sh /usr/local/study/kafka/kafka_2.11-2.2.1/config/server.properties5:测试
- 创建主题
[root@localhost logs]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test Created topic test.
- 查看主题
[root@localhost logs]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-topics.sh --list --zookeeper localhost:2181 test
- 生产消息
[root@localhost ~]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic jianguan_workflow_test >你好 >好哈好
- 消费消息
[root@localhost ~]# /usr/local/study/kafka/kafka_2.11-2.2.1/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic jianguan_workflow_test --from-beginning 你好 好哈好
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)