Centos 7 安装zookeeper + kafka单机例子

港控/mmm° 2021-10-01 00:22 513阅读 0赞

写的不好主要是为了自己看

下载好zookeeper和kafka后，解压好后

先开始zookeeper

打开conf中有一个zoo_sample.cfg复制此文件改为名字zoo.cfg

修改zoo.cfg

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70

vim /etc/profile

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70 1

在末尾加入如图

  1. #idea - zookeeper-3.4.9 config start - 2017-12-09
  2. export ZOOKEEPER_HOME=/usr/local/services/zookeeper/zookeeper-3.4.9/
  3. export PATH=$ZOOKEEPER_HOME/bin:$PATH
  4. export PATH
  5. #idea - zookeeper-3.4.9 config end - 2017-12-09

source /etc/profile

启动 zookeeper 服务：
zkServer.sh start

查询 zookeeper 状态：
zkServer.sh status

关闭 zookeeper 服务：
zkServer.sh stop

重启 zookeeper 服务：
zkServer.sh restart

以上是zookeeper，下面是kafka

下载解压不写

vim server.properties

主要更改

log.dirs=/usr/local/kafka_2.12-2.1.0/logs/kafka
listeners=PLAINTEXT://（你的ip）:9092

zookeeper.connect=114.67.100.229:2181

启动

./bin/kafka-server-start.sh -daemon config/server.properties

查看线程

netstat -tunlp|egrep “(2181|9092)”

创建topic

./bin/kafka-topics.sh —create —zookeeper ip:2181 —replication-factor 1 —partitions 1 —topic test-topic

生产者：

./bin/kafka-console-producer.sh —broker-list ip:9092 —topic test_topics

消费者：

./bin/kafka-console-consumer.sh —bootstrap-server ip:9092 —topic test_topics —from-beginning

发表评论

表情：
评论列表 （有 0 条评论，513人围观）

还没有评论，来说两句吧...

相关阅读