kafka安装教程

 时间:2024-10-12 18:15:51

1、kafka官网下载 kafka_2.10-0.8.2.1.tgz并复制到虚拟机Ubuntu

2、1解压到该路径tar zxvf kafka_2.10-0.8.2.1.tgzsudo mv kafka /home/chen-pc/kafka

3、启动和停止启动Zookeeper server:Shell代码bin/zookeeper-server-start.sh config/zookeeper.properties & 其中&是为了能退出命令行

kafka安装教程

4、停止Kafka serverShell代码bin/kafka-server-stop.sh 出现如下:INFO Shutting down. (kafka.log.LogManager)INFO Shutdown complete. (kafka.log.LogManager)INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)INFO Session: 0x154957ee6bc0000 closed (org.apache.zookeeper.ZooKeeper)INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer)

kafka安装教程

5、停止Zookeeper server:Shell代码bin/zookeeper-server-stop.sh 出现如下:[1]+ Exit 130 bin/zookeeper-server-start.sh config/zookeeper.properties

kafka安装教程

6、创建启咿蛙匆盗动、关闭kafka脚本cd /home/chen-pc/kafka创建启动脚本vi kafkastart.sh #编辑,添加以下代码#!/bin/sh#启动zookeeper/home/chen-pc/kafka/bin/zookeeper-server-start.sh /home/chen-pc/kafka/config/zookeeper.properties &#等3秒后执行sleep 3#启动kafka/home/chen-pc/kafka/bin/kafka-server-start.sh /home/chen-pc/kafka/config/server.properties &保存退出vi kafkastop.sh #编辑,添加以下代码#!/bin/sh#关闭zookeeper/home/chen-pc/kafka/bin/zookeeper-server-stop.sh /home/chen-pc/kafka/config/zookeeper.properties &sleep 3#关闭kafka/home/chen-pc/kafka/bin/kafka-server-stop.sh /home/chen-pc/kafka/config/server.properties &添加脚本执行权限chmod +x kafkastart.shchmod +x kafkastop.sh以后启动kafka sh /home/chen-pc/kafka/kafkastart.shJps查看进程

kafka安装教程

7、关闭kafka sh /home/chen-pc/kafka/kafkastop.sh至此,Linux下Kafka单机安装配置完成。

8、单节点kafkash /home/chen-pc/kafka/kafkastart.shKafka创建topiccd kafkabin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

kafka安装教程

9、Kafka 删除topicbin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test查看topic/home/chen-pc/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181

kafka安装教程

10、启动consumer & producer,并在producer启动后的console输入一些信息b足毂忍珩in/kafka-console-producer.sh --broker-list localhost:9092 --topic testbin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

kafka安装教程

11、Kafka安装部署成功

  • VS2013怎么设置使用启发式XML文件的配置
  • Eclipse Regions模块入门介绍
  • eclipse自定义new菜单Dynamic Web Project为例
  • MySQL如何设置主机和端口号#校园分享#
  • 分布式系统常见问题及解决方案
  • 热门搜索
    丁克是什么意思 鱼鳔的作用 梦见亲人去世是什么意思 任重道远的意思 尕是什么意思 开什么店比较好 propose什么意思 拖泥带水的意思 股市什么时候开市 加工费计入什么科目