汪微的博客
zane,做一个有思维的开发者

汪微的博客

kafka的安装和常用基本命令说明

2019年01月16日133 browse

一:  MAC安装kafka

安装:

kafka依赖java环境,因此你可能需要先安装好java环境。

// mac 环境使用brew直接安装kafka
brew install kafka 

// 卸载
brew uninstall kafka

mac 安装kafka过程中会自动的安装好zookeeper。

启动:

// 启动
brew services start kafka
brew services start zookeeper

// 重启
brew services restart kafka
brew services restart zookeeper


二:Linux安装kafka

一、进入官网下载安装包

http://kafka.apache.org/downloads

下载Binary包如下图,下面以2.1.0版本为例:



备注:此处有Source包和Binary包,此处需要选择Binary包。

cd /usr/src
// 下载包
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.12-2.2.0.tgz

// 解压
tar -xzf kafka_2.12-2.2.0.tgz
// 重命名为kafka
mv kafka_2.12-2.2.0 kafka

cd kafka


前台启动Zookeeper 和kafka

bin/zookeeper-server-start.sh config/zookeeper.properties

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


后台启动Zookeeper 和kafka

bin/zookeeper-server-start.sh config/zookeeper.properties 1>/dev/null  2>&1  &

bin/kafka-server-start.sh config/server.properties 1>/dev/null  2>&1  &

其中1>/dev/null 2>&1 是将命令产生的输入和错误都输入到空设备,也就是不输出的意思。/dev/null代表空设备。


kafka配置说明:

配置文件server.properties

// mac 电脑配置文件地址
vim /usr/local/etc/kafka/server.properties

// Linux 配置文件地址
vim /usr/src/kafka/config/server.properties

配置参考地址:

http://www.orchome.com/472

备注: 尽量配置host.name, 例如本地的配置

host.name = 127.0.0.1
port=9092


常用基本命令:

创建一个主题(topic)

// mac
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

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


删除topic

// mac 
kafka-topics  --delete --zookeeper localhost:2181 --topic 【topic name】

// linux 
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic 【topic name】


查看创建的topic list

// mac
kafka-topics --list --zookeeper localhost:2181

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


生产消息

// mac 
kafka-console-producer --broker-list localhost:9092 --topic test

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


消费消息

// mac 
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

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


更多使用方式可参考:http://www.orchome.com/454


博主 zane 发表于 2019-01-16 16:05:35,添加在了 其他 标签下

打赏

您的支持将鼓励我继续努力与分享。

扫码打赏,建议金额1-10元

提醒:打赏金额将直接进此方账号,无法退款,请您谨慎操作。

评论

正在加载验证码......

提交