kafka单机搭建
1.安装jdk1.8和zookeeper
2.下载kafka上传服务器
下载地址：http://archive.apache.org/dist/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz
修改配置文件/usr/kafka_2.11-0.10.0.0/config/server.properties
log.dirs=/usr/kafka_2.11-0.10.0.0/logs #创建此目录
修改配置文件/usr/kafka_2.11-0.10.0.0/config/zookeeper.properties
dataDir=/usr/zookeeper #zookeeper安装地址
后台启动zookeeper： nohup bin/zookeeper-server-start.sh config/zookeeper.properties 2>&1 &
后台启动kafka： nohup bin/kafka-server-start.sh config/server.properties 2>&1 &
3.测试
创建topic：
bin/kafka-topics.sh --create --zookeeper ip:2181 --replication-factor 2 -- partitions 3 --topic test
查看topic：
bin/kafka-topics.sh --list --zookeeper ip:2181
生产数据：
bin/kafka-console-producer.sh --broker-list ip:9092 --topic test
消费者消费数据：
bin/kafka-console-consumer.sh --from-beginning --topic test --zookeeper ip:2181
最新文章
- python高级之多进程
- ThinkPHP魔术方法
- GridView用法大全（转）
- STL源码分析读书笔记--第二章--空间配置器（allocator）
- JQUERY1.9学习笔记 之内容过滤器(三) has选择器
- 蓝桥杯-算法训练--ALGO-5 最短路
- php多个文件上传
- 恶补web之八:jQuery(2)
- 圆周率pi π 与 角度的对应关系
- 实现Linux下od -tx -tc XXX的功能
- PHP（层叠样式表，写法分类），选择器的种类）
- CVE-2018-8120 Windows权限提升
- 不一样的go语言-构建系统与构件系统
- 回车和刷新以及Ctr+F5的区别
- 【java编程】加密算法-对称加密及AES加密算法
- Android开发最佳实践《IT蓝豹》
- EOS开发基础之二：使用cleos命令行客户端操作EOS（钱包wallet基础操作）
- Luogu 1613 跑路（最短路径，倍增）
- MLCC Y5V 和 X7R 电容记录
- 修改MVC视图默认搜索规则（IViewEngine）