kafka的基本安装与使用
kafka的基本安装与使用
1、上官网下载tar包
2、解压
3、运行zookeeper
4、运行kafka服务器
5、创建topic
6、发送消息
7、监听消息
1、上官网下载tar包
https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.12-2.2.0.tgz
2、tar包上传到服务器
tar -zxvf kafka_2.12-2.2.0.tgz
3、运行zookeeper
切换到解压目录
运行
bin
/zookeeper-server-start
.sh config
/zookeeper
.properties &
4、运行kafka服务器
修改配置文件
vim config/server.properties
bin/kafka-server-start.sh config/server.properties &
5、创建topic
创建名为 test的topic
bin
/kafka-topics
.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic
test
查看主题数量
bin
/kafka-topics
.sh --list --bootstrap-server localhost:9092
6、发送消息
bin
/kafka-console-producer
.sh --broker-list localhost:9092 --topic
test
this is a message;
7、监听消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
最新文章
- CSS控制表格(table)样式
- XE8 &; IOS开发之免费证书真机调试:开发证书、AppID、开发授权profile的申请,附Debug真机调试演示(XCode7 Beta版或以上版本适用,有图有真相)
- win7+vs2010+opencv2.4.6配置
- 性能测试学习之二 ——性能测试模型(PV计算模型)
- G面经prepare: Data Stream Average
- 翻译「C++ Rvalue References Explained」C++右值引用详解 Part4:强制Move语义
- Pure扩展站--个人博客
- 搜索浅谈(Elasticsearch和Lucene4分享)
- Gnuradio 学习
- 把虚拟机中的Linux系统安装到U盘中
- 暑假练习赛 006 E Vanya and Label(数学)
- FusionCharts封装-dataset和categories
- Boosting(提升方法)之AdaBoost
- BZOJ2527[Poi2011]Meteors——整体二分+树状数组
- echarts 滚动条 缩放
- 引用全局变量global
- S5PV210 PWM定时器
- 构建模式--Adapter模式(JAVA)
- Jmeter测试计划要素
- encoding/path可能引起无数奇怪的问题