社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
安装包(Linux环境):
安装:
tickTime=2000
dataDir=/opt/zookeeper-3.4.6/data
clientPort=2181
$ ./zkServer.sh start
JMX enabled by defaultUsing config: /opt/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
$ ./zkServer.sh status //查看状态
JMX enabled by default
Using config: /opt/zookeeper/bin/../conf/zoo.cfg
Mode: standalone
$ jps //查看进程
13786 QuorumPeerMain
$ ./zkCli.sh
或
$ ./zkCli.sh -server IP(127.0.0.1或实际ip地址):2181
配置并启动kafka
1.进入/kafka_2.11-0.10.1.0/config目录,在server.properties中添加如下配置
broker.id=0
listeners = PLAINTEXT://实际IP:9092
log.dirs=/home/hadoop/kafka-logs
zookeeper.connect=实际IP:2181
zookeeper.connection.timeout.ms=60000
$ kafka-server-start.sh $KAFKA_HOME/config/server.properties
[root@host-03 config]# jps
23600 Kafka
24193 ConsoleConsumer
13786 QuorumPeerMain
23946 ConsoleProducer
25036 Jps
[root@host-03 config]# jps -m
23600 Kafka /home/kafka_2.11-0.10.1.0/config/server.properties
24193 ConsoleConsumer --bootstrap-server IP:9092 --topic di62 --from-beginning
13786 QuorumPeerMain /home/kafka/zookeeper-3.3.6/bin/../conf/zoo.cfg
23946 ConsoleProducer --broker-list IP:9092 --topic di62
25051 Jps -m
./kafka-topics.sh --create --zookeeper IP地址:2181 --replication-factor 1 --partitions 1 --topic di62
参数说明:
–zookeeper:指定kafka连接zk的连接url,该值和server.properties文件中的配置项{zookeeper.connect}一样
–replication-factor:指定副本数量
–partitions:指定分区数量
–topic:主题名称
./kafka-topics.sh --list --zookeeper IP地址:2181
./kafka-console-producer.sh --broker-list IP地址:9092 --topic di62
7.启动消费者(新版本)
./kafka-console-consumer.sh --bootstrap-server 192.168.16.167:9092 --topic di62 --from-beginning
安装包下载地址:链接: https://pan.baidu.com/s/1W1Fsqta4qxG7mHsqwZSH4A 提取码: uft8
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!