windows 安装kafka 2.8.1
电脑上的前置的条件为
1、在电脑上有安装jdk
2、2.8.1中的kafka版本里面有包含了zookeeper,故此本版本不需要安装zookeeper
第一步:到kafka官网上找安装包
我是使用的网址为以下地址:包一定别选错了 kafka_2.13-2.8.1.tgz
http://archive.apache/dist/kafka/2.8.1/
第二步 安装+配置
将下载下来的安装包(kafka_2.13-2.8.1.tgz)解压到指定文件夹:如图我是解压到了D盘
文件目录是这样子的
D:\kafka_2.13-2.8.1\config 文件的目录下你能看到
server.properties
zookeeper.properties
第三步 启动配置卡夫卡
第一步首先要启动 zookeeper 服务
弹出终端,然后输入命令 启动zookeeper命令(一定要先启动zookeeper)
简单的说无论你在安装在那个目录下,这个命令直接在你安装的目录下启动cmd执行该命令;
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
当你看到这个的时候说明你启动成功了,接下来启动kafka程序
同样的操作在安装文件的根目录 cmd 调出终端窗口
输入.\bin\windows\kafka-server-start.bat .\config\server.properties
有这个打印的时候说明安装成功了;
停止服务 来个方法 一个直接在启动服务的终端直接CTRL+c就能停止服务;
以上就完成了windows的kafka的安装了。有问题欢迎交流
第四步 测试
1、我们先创建一个topic
创建topic得命令为
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
注: 这个命令得注解为
–replication-factor 1 : 表示创建一个通知队列
–partitions 1 :表示创建一个分片
–topic 主题名称 :该命令中创建了一个主题名称为 test-topic得主题
命令一定是要在 安装的目录D:\kafka_2.13-2.8.1\bin\windows 下执行
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
出现下图表示topic创建成功
2、我们创建一个生产者
同样的道理到,安装的目录D:\kafka_2.13-2.8.1\bin\windows 下执行
kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic
–broker-list:表示消息创建的是时候是list形式
如下图所示表示创建生成者成功
3、我们创建一个消费者
在安装的目录D:\kafka_2.13-2.8.1\bin\windows 打开一个新的CMD页面
执行命令 kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic
如下图所示表示成功
上图所示是两个CMD窗口。到这里整个2.8.1的kafka就安装完成了,并能成功的发送消息!!若有疑问欢迎留言交流
创建主题 test-topic
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
启动消费者
kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic
启动生产者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic
查看消费组
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
查看主题命令
kafka-topics.bat --list --bootstrap-server localhost:9092