kafka的安装和常用基本命令说明
2019年01月16日989 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
配置参考地址:
备注: 尽量配置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,添加在了 其他
标签下打赏
您的支持将鼓励我继续努力与分享。


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