Kafka的简单使用

ZooKeeper安装与配置

在Apache ZooKeeper下载Zookeeper，然后用tar -zxvf 原压缩文件 -C 解压后的目录，然后配置安装目录conf/zoo_sample.cfg文件，主要配下面这几个就行，然后把zoo_sample.cfg用mv改名zoo.cfg.

# 服务与zookeeper的最大心跳
tickTime=2000 
# 数据存储目录
dataDir=/var/lib/zookeeper
# 提供服务的端口
clientPort=2181

最后到安装目录下的bin目录下用zkServer.sh start就启动了(这里建议可以把zookeeper配置到环境变量,下面的kafka也是)

> zkServer.sh start

Kafka安装与配置

到Apache Kafka
下载二进制文件，同样用tar解压，然后到config文件夹里面配置server.properties文件，主要配置如下

broker.id=0
listerners=PLAINTEXT://broker服务器的ip:9092
log.dirs=日志文件夹
zookeeper.connect=zookeeper服务器的ip:2181

然后就到Kafka安装目录下的bin文件夹下用使用如下命令

# 启动Kafka服务端
> kafka-server-start.sh ../config/server.properties

到Kafka安装目录下的bin文件夹下用使用如下命令，创建一个副本为1，分区为1的主题

> kafka-topics.sh --bootstrap-server 要连接的broker的ip:端口 --create --topic test --partitions 1 --replication-factor 1

用KafkaTemplate进行生产和消费

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。