Kafka 安装配置 及 简单实验记录
2024-09-24 21:31:43
1. 下载二进制文件并解压,并修改 broker.id 的值
wget http://apache.fayea.com/kafka/0.10.0.0/kafka_2.10-0.10.0.0.tgz
tar -xzf kafka_2.-0.10.0.0.tgz
cd kafka_2.-0.10.0.0 # 修改 config/server.properties 中的 broker.id 的值,由于是 localhost 模式,故把 kafka 的节点数设为 ,即 broker.id=
2. 开启zookeeper server 和 kafka server
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties 注意:后台启动可以用nohup,比如:
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > myout.file 2>&1 &
3. 创建一个topic 然后 查看创建的topic,之后不需要重复创建
bin/kafka-topics.sh --create --zookeeper localhost: --replication-factor --partitions --topic test
bin/kafka-topics.sh --list --zookeeper localhost:
4. 发送一些message
bin/kafka-console-producer.sh --broker-list localhost: --topic test #然后发送一些消息:
This is a message
This is another message
5. 启动一个consumer
bin/kafka-console-consumer.sh --zookeeper localhost: --topic test --from-beginning #然后控制台会输出下面的消息
This is a message
This is another message
最新文章
- 了不起的 nodejs-TwitterWeb 案例 bug 解决
- C# oracle odp.net 32位/64位版本的问题
- 三分之一的程序猿之社交类app踩过的那些坑
- java.lang.Long cannot be cast to java.lang.Integer解决办法
- MVC文件夹
- Redis Cluster架构和设计机制简单介绍
- hdu 2709 Sumsets
- 如何将一个Form中的代码拆分到多个文件中
- 关于C#控制台传递参数和接收参数
- Linux下安装memcache
- Spark应用程序的运行框架
- 图数据库 Titan 高速入门
- hdu1198--并查集
- 部署 instance 到 OVS vlan100 - 每天5分钟玩转 OpenStack(138)
- iOS 横竖屏适配 笔记
- Node.js 中的 stream
- js反爬-从入门到精通webdriver
- php优秀框架codeigniter学习系列——CI_Controller分析
- linux --- 5. nginx 初始
- base标签浏览器兼容问题