kafka与zookeeper下载安装及kafka常用命令

一、zookeeper

1、下载

下载地址 https://zookeeper.apache.org/releases.html

2、修改配置文件及host

解压到安装路径
修改hosts

vim /etc/hosts
添加域名映射
192.168.10.200 kafka200
192.168.10.201 kafka201
192.168.10.202 kafka202

修改zoo.cfg

cd apache-zookeeper-3.7.0-bin/conf
修改zoo.cfg
修改data目录

3、启动

nohup /home/kafka/soft_install/apache-zookeeper-3.7.0-bin/bin/zkServer.sh start >> /home/kafka/soft_install/apache-zookeeper-3.7.0-bin/logs/zook.log &

使用jps查看启动情况

二、kafka

1、下载

https://kafka.apache.org/downloads

2、修改配置文件及host

进入kafka_2.12-2.8.0/config
修改以下内容
broker.id=0
port=9092
listeners = PLAINTEXT://kafka200:9092
advertised.listeners=PLAINTEXT://kafka200:9092
zookeeper.connect=kafka200:2181,kafka201:2181,kafka202:2181
#这里是集群配置，broker.id要唯一，zookeeper.connect为zookeeper地址，zookeeper与kafka用的是同一机器，所以不用配置host了

3、启动

nohup /home/kafka/soft_install/kafka_2.12-2.8.0/bin/kafka-server-start.sh /home/kafka/soft_install/kafka_2.12-2.8.0/config/server.properties >> /home/kafka/soft_install/kafka_2.12-2.8.0/logs/kafka.log &

三、kafka常用shell命令

1、创建topic
./kafka-topics.sh --create --topic topicDemo --bootstrap-server kafka200:9092
2、查看topic
./kafka-topics.sh --describe --topic topicDemo --bootstrap-server kafka200:9092
3、发送消息
./kafka-console-producer.sh --topic topicDemo --bootstrap-server kafka200:9092
4、消费消息
./kafka-console-consumer.sh --topic topicDemo --bootstrap-server kafka200:9092
5、查看topic列表
./kafka-topics.sh --list --zookeeper kafka200:2181
6、列出消费者组信息
./kafka-consumer-groups.sh --bootstrap-server kafka200:9092 --list
7、查看某个group 消费情况
./kafka-consumer-groups.sh --bootstrap-server kafka200:9092 --describe --group testGroup
8、重置group offset 为earliest
./kafka-consumer-groups.sh --bootstrap-server kafka200:9092 --group testGroup --reset-offsets --topic topicDemo --to-earliest --execute
9、重置group offset 为latest
./kafka-consumer-groups.sh --bootstrap-server kafka200:9092 --group testGroup --reset-offsets --topic topicDemo --to-latest --execute
10、从头消费
./kafka-console-consumer.sh  --bootstrap-server kafka200:9092 --topic topicDemo -group testGroup1 --from-beginning需满足两个条件条件1， 使用一个全新的消费者组id；条件2，指定 auto.offset.reset 为 earliest ；

kafka与zookeeper下载安装及kafka常用命令相关推荐

Docker学习 (一) 下载安装及基本常用命令
Docker快速入门笔记 1.docker概述 1.1.docker基本介绍 Docker 是一个开源的应用容器引擎,基于 Go 语言并遵从 Apache2.0 协议开源,让开发者可以打包他们的应用 ...
SDK完整环境下载安装及ADB常用命令
最近在配置Android 开发环境的时候遇到了一个大问题,那就是Google Android的官网居然成功的被我天朝给墙掉了,想想俺当年开发Android的时候,那网站都还妥妥地上得去啦这个世界变得真 ...
zookeeper下载安装、zookeeper-3.4.6下载安装、Windows启动zookeeper、zookeeper启动闪退解决、\..\conf\zoo.cfg file is missin
zookeeper下载安装.zookeeper-3.4.6下载安装.Windows启动zookeeper.zookeeper启动闪退解决.zookeeper找不到zoo.cfg配置:\..\conf\ ...
【MAC、Windows系统的node版本管理工具——nvm】nvm的安装、nvm常用命令、nvm设置默认 node 版本
nvm 目录总结 nvm 的使用 1. nvm 安装 2. nvm 常用命令总结总结在我们的实际开发过程中,需要使用 nvm use vxx 将 node 版本设置成其他更高或更低的版本,但是 ...
下载安装Go SDK、命令运行及在GoLand中运行第一个HelloWorld
文章目录下载安装Go SDK.命令运行及在GoLand中运行第一个HelloWorld 1.下载Go SDK 2.安装Go SDK 3.go version验证成功 4.go env查看配置信息 5 ...
Linux系统Vi/Vim编辑器的简单介绍、安装/卸载、常用命令
Linux系统Vi/Vim编辑器的简单介绍.安装/卸载.常用命令 1.介绍 vi(Visual Interface)编辑器是Linux和Unix上最基本的文本编辑器,工作在字符模式下.由于不需要图形界 ...
下载安装Go SDK、命令运行及在Vscode中运行第一个HelloWorld
文章目录下载安装Go SDK.命令运行及在Vscode中运行第一个HelloWorld 1.下载Go SDK 2.安装Go SDK 3.go version验证成功 4.go env查看配置信息 5 ...
kafka和zookeeper下载地址和安装方法和JAVA消费者方法
kafka下载地址:http://archive.apache.org/dist/kafka/3.0.1/kafka_2.13-3.0.1.tgz zookeeper下载地址:http://archi ...
zookeeper下载安装过程
1.1 下载安装 1.环境准备 ZooKeeper服务器是用Java创建的,它运行在JVM之上.需要安装JDK 7或更高版本. 2.上传将下载的ZooKeeper放到/opt/ZooKeeper目录 ...
Zookeeper下载安装教程(windows系统)
Zookeeper简介 ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件.它是一个为分布式应用提供一 ...

kafka与zookeeper下载安装及kafka常用命令

kafka与zookeeper下载安装及kafka常用命令

一、zookeeper

1、下载

2、修改配置文件及host

3、启动

二、kafka

1、下载

2、修改配置文件及host

3、启动

三、kafka常用shell命令

kafka与zookeeper下载安装及kafka常用命令相关推荐

最新文章

热门文章