欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

单机版kafka安装

程序员文章站 2022-05-27 16:42:12
...
一.下载配置
  1. 下载最新安装包
wget http://mirror.bit.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
  1. 解压安装包
tar -xzvf kafka_2.11-2.0.0.tgz
  1. 修改Server.properties文件
vim kafka_2.11-2.0.0/config/server.properties

listeners = PLAINTEXT://your.host.name:9092
advertised.listeners=PLAINTEXT://your.host.name:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

二.启动

进入kafka_2.11-2.0.0目录下执行

  1. 启动zookeeper,单机版启动kafka自带的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
  1. 启动kafka
bin/kafka-server-start.sh config/server.properties
  1. 创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-1025
  1. 查看所有topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
  1. 查看topic信息
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-1025
  1. 创建生产者
bin/kafka-console-producer.sh --broker-list zk-master01:9092 --topic test-1025
  1. 创建消费者
bin/kafka-console-consumer.sh --bootstrap-server zk-master01:9092 --topic test-1025 --from-beginning

相关标签: kafka Linux