没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
1.下载地址 http://kafka.apache.org(2.11-1.10版本才与JDK1.7兼容)
2.修改config目录中:vi server.properties
broker.id=0
port=9092
host.name=localhost
log.dirs=/opt/kafka/kafka_2.11-1.10/log
zookeeper.connect=localhost:2181
3.进入kafka目录下 config目录下输入命令:vi zookeeper.properties
修改内容为:
dataDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataDir #zookeeper数据目录 (可以修改可以不修改)
dataLogDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataLogDir #zookeeper日志目录 (可以修改可以不修改)
clientPort=2181
maxClientCnxns=100
tickTime=2000
initLimit=10
4.启动服务
1.启动Zookeeper(后台启动) : ./zookeeper-server-start.sh ../config/zookeeper.properties 1>/dev/null 2>&1 &
2.启动Zookeeper(前台启动) : ./zookeeper-server-start.sh ../config/zookeeper.properties
3.启动kafka(后台启动) : ./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
4.启动kafka(前台启动) : ./kafka-server-start.sh ../config/server.properties
5.创建一个主题Topic
./kafka-topics.sh --create --zookeeper localhost:2181 --config max.message.bytes=12800000 --config flush.messages=1 --replication-factor 1 --partitions 1 --topic test
6.查看已创建的topic信息
./kafka-topics.sh --list --zookeeper localhost:2181
2.修改config目录中:vi server.properties
broker.id=0
port=9092
host.name=localhost
log.dirs=/opt/kafka/kafka_2.11-1.10/log
zookeeper.connect=localhost:2181
3.进入kafka目录下 config目录下输入命令:vi zookeeper.properties
修改内容为:
dataDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataDir #zookeeper数据目录 (可以修改可以不修改)
dataLogDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataLogDir #zookeeper日志目录 (可以修改可以不修改)
clientPort=2181
maxClientCnxns=100
tickTime=2000
initLimit=10
4.启动服务
1.启动Zookeeper(后台启动) : ./zookeeper-server-start.sh ../config/zookeeper.properties 1>/dev/null 2>&1 &
2.启动Zookeeper(前台启动) : ./zookeeper-server-start.sh ../config/zookeeper.properties
3.启动kafka(后台启动) : ./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
4.启动kafka(前台启动) : ./kafka-server-start.sh ../config/server.properties
5.创建一个主题Topic
./kafka-topics.sh --create --zookeeper localhost:2181 --config max.message.bytes=12800000 --config flush.messages=1 --replication-factor 1 --partitions 1 --topic test
6.查看已创建的topic信息
./kafka-topics.sh --list --zookeeper localhost:2181
资源评论
中科院、阿坤
- 粉丝: 3
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功