kafka学习（一安装）

Posted 2021-05-02 超仔个人空间

        今天记录下自己开始学习kafka的经验，首先我们先说在windows环境下的安装部署。

        安装很简单只需要下载kafka大家可以去官网自行下载，我这里下载的是kafka_2.12-1.0.0下载完成后我们解压到指定文件夹下面F:\eclipse-oxy\kafka我自己新建的路径，进入F:\eclipse-oxy\kafka\kafka_2.12-1.0.0\config这里面有两个可能会用到的配置文件一个是zookeeper.properties另一个是server.properties

第一个是启动zookeeper的一个是启动kafka的。

        其中zookeeper.properties中我只修改了dataDir=F:/eclipse-oxy/kafka/logs/zookeeper，server.properties我只修改了

log.dirs=F:/eclipse-oxy/kafka/logs/kafka

其中zookeeper.connect=localhost:2181这是需要注意的地方

配置完成后我们就可以启动了，首先启动zookeeper，进入到F:\eclipse-oxy\kafka\kafka_2.12-1.0.0目录

执行.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

看到结果

启动成功了。

然后启动kafka进入到F:\eclipse-oxy\kafka\kafka_2.12-1.0.0目录

执行 .\bin\windows\kafka-server-start.bat .\config\server.properties

启动完成如果失败建议删除F:\eclipse-oxy\kafka\kafka_2.12-1.0.0\eclipse-oxykafkalogskafka下的文件

然后创建topic

执行 bin\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

partitions 分区

replication-factor表示该topic需要在不同的broker中保存几份，这里replication-factor设置为1, 表示在一个broker中保存。 

剩下的就是生产者和消费者的代码了

生产者：

消费者：

props.put("group.id", "0");其中如果启动两个相同的grou.id则只有一个消费者可以收到信息，如果想都收到就要创建多个group.id就是说一个组中一个消费者消费某一个topic今天就说到这里后面再讲其他的。

感兴趣的小伙伴们多转发也可以关注我提出你的问题和建议，让我一起学习进步。