温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Linux系统中如何安装配置Kafka

发布时间:2022-01-24 14:59:28 来源:亿速云 阅读:206 作者:清风 栏目:开发技术

这篇文章主要为大家展示了Linux系统中如何安装配置Kafka,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带大家一起来研究并学习一下“Linux系统中如何安装配置Kafka”这篇文章吧。

Linux系统安装配置Kafka具体步骤

下载Kafka

http://archive.apache.org/dist/kafka/1.1.0/

解压并重命名

 cd /usr/local
 tar zxvf kafka_2.12-1.1.0.tgz
 mv kafka_2.12-1.1.0 kafka_2.12-1.1.0/

配置kafka

 mkdir /usr/local/kafka/log/kafka #创建kafka日志目录
 cd /usr/local/kafka/config #进入配置目录
 vi server.properties #编辑修改相应的参数
 
 broker.id=0
 port=9092 #端口号
 host.name=hostname #hostname
 listeners=PLAINTEXT://hostname:9092
 log.dirs=/usr/local/kafka/log/kafka #日志存放路径,上面创建的目录
 zookeeper.connect=localhost:2181 #zookeeper地址和端口,单机配置部署,localhost:2181

配置zookeeper

 mkdir /usr/local/kafka/zookeeper #创建zookeeper目录
 mkdir /usr/local/kafka/log/zookeeper #创建zookeeper日志目录
 cd /usr/local/kafka/config #进入配置目录
 vi zookeeper.properties #编辑修改相应的参数
 
 dataDir=/usr/local/kafka/zookeeper #zookeeper数据目录
 dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目录
 clientPort=2181
 maxClientCnxns=100
 tickTime=2000
 initLimit=10
 syncLimit=5

以上配置使用了kafka自动的zookeeper,无需单独安装一个zookeeper

启动脚本

 vi kafkastart.sh     #编辑,添加以下代码
 
 #!/bin/sh
 
 #启动zookeeper
 /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
 
 sleep 3   #等3秒后执行
 
 #启动kafka
 /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

停止脚本

 vi kafkastop.sh #编辑,添加以下代码
 
 #!/bin/sh
 
 #关闭zookeeper
 /usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties &
 
 sleep 3 #等3秒后执行
 
 #关闭kafka
 /usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &

创建一个Topic

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

上述命令为创建一个副本数为1,分区数为1的,名字为test的topic

查看Topic

 bin/kafka-topics.sh --list --zookeeper localhost:2181

发送消息

 bin/kafka-console-producer.sh --broker-list hostname:9092 --topic test

消费消息

 bin/kafka-console-consumer.sh --bootstrap-server hostname:9092 --topic test --from-beginning

注意hostname和配置中的hostname必须一致

什么是Linux系统

Linux是一种免费使用和自由传播的类UNIX操作系统,是一个基于POSIX的多用户、多任务、支持多线程和多CPU的操作系统,使用Linux能运行主要的Unix工具软件、应用程序和网络协议。

以上就是关于“Linux系统中如何安装配置Kafka”的内容,如果该文章对您有所帮助并觉得写得不错,劳请分享给您的好友一起学习新知识,若想了解更多相关知识内容,请多多关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI