已搭建Zookeeper 并确保zookeeper已启动
环境准备Kafka kafka_2.11-1.0.0.tgz压缩包 添加链接描述
上传服务器tar -xvf kafka_2.11-1.0.0.tgz mv kafka_2.11-1.0.0 kafka //文件夹更名 mkdir log.dirs=/usr/local/kafka/kafka-logs ---创建存放kafka数据路径修改配置文件
vi config/server.properties 需要修改属性 1 boroker.id = 0 //可自定义 不重复即可 2 listeners = PLAINTEXT://9092 ----去除“#”即可 3 log.dirs=/usr/local/kafka/kafka-logs ----创建存放数据目录 4 zookeeper.connect = zk地址:端口号 ---修改为自己的zookeeper地址+端口 5 zookeeper.connection.timeout.ms= 6000 ---可修改为30000服务启动
cd bin sh kafka-server-start.sh ../config/server.properties ---启动kafka服务安装验证
当前操作 在/bin目录下 ----zookeeper上创建一个topic partition数为1 sh kafka-topics.sh --zookeeper zk地址:端口 --create --replication-factor 1 --partitions 1 --topic first 开启生产者 : sh kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first 开启消费者: sh kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic first -- from beginning防火墙允许端口访问
#允许端口开放 firewall-cmd --zone=public --add-port=9092/tcp --permanent远程可访问
