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进行生产和消费