docker安装kafka快速入门
docker安装kafka快速入门
1.安装zookeeper
docker search zookeeper
docker pull zookeeper
docker run -d -v /home/soft/zookeeperhost/zookeeperDataDir:/data -v /home/soft/zookeeperhost/zookeeperDataLogDir:/datalog --name zookeeper -p 2181:2181 zookeeper
2.安装kafka
docker search kafka
docker pull wurstmeister/kafka
docker run -d --name kafka -p 9092:9092 --env KAFKA_ADVERTISED_HOST_NAME=localhost -e KAFKA_ZOOKEEPER_CONNECT=localhost:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" wurstmeister/kafka
3.登录kafka,创建主题,发送消息,接受消息
a.进入kafka
docker exec -it kafka bash
cd /opt/kafka_2.11-2.0.0/bin/
b.创建名为test的主题
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test
c.创建提供者
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
d.另起一个标签,执行如下命令 创建kafka消费者消费消息:
docker exec -it kafka bash
cd /opt/kafka_2.11-2.0.0/bin/
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
最新文章
- Cell右滑 多个编辑选项栏
- 设计模式之美:Interpreter(解释器)
- Atitit 编程语言原理与概论attilax总结
- LeetCode(43. Multiply Strings)
- ubuntu下使用nginx部署Laravel
- Linux环境下的Nodejs
- Java设计模式之简单工厂、工厂方法和抽象工厂
- BZOJ2292: 【POJ Challenge 】永远挑战
- linux之awk
- SpringMVC Memcached 搭建WEB项目缓存框架
- centos7.2自带的php5.4升级为5.6
- Git学习 -- 分支管理
- FunDA:一个开源的函数式数据处理工具库,也是Slick的补充
- 空a标签 a标签空的情况下 IE6 IE7下点击无效
- 爬虫之requests模块
- session和cookie的简介
- NHibernate:no persister for 异常
- 【C++】C++中变量的声明与定义的区别
- Python全栈之路----常用模块----random模块
- JAVA基础知识点总结(全集)
热门文章
- JavaScript异步与Promise基本用法(resolve与reject)
- Leetcode之动态规划(DP)专题-122. 买卖股票的最佳时机 II(Best Time to Buy and Sell Stock II)
- web赛题3
- (转)asp.net mvc 开发环境下需要注意的安全问题(一)
- Go语言中的打包和工具链
- 基于Docker 搭建 Jenkins
- paramiko模块(远程操作服务器)
- day03-04
- Codeforces 1237F. Balanced Domino Placements
- Codeforces 1238C. Standard Free2play