惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

S
SegmentFault 最新的问题
J
Java Code Geeks
V
V2EX
Blog — PlanetScale
Blog — PlanetScale
博客园 - 司徒正美
Hugging Face - Blog
Hugging Face - Blog
F
Fortinet All Blogs
aimingoo的专栏
aimingoo的专栏
B
Blog
A
About on SuperTechFans
有赞技术团队
有赞技术团队
月光博客
月光博客
Microsoft Azure Blog
Microsoft Azure Blog
阮一峰的网络日志
阮一峰的网络日志
腾讯CDC
美团技术团队
大猫的无限游戏
大猫的无限游戏
爱范儿
爱范儿
N
Netflix TechBlog - Medium
C
Check Point Blog
Recent Announcements
Recent Announcements
博客园 - Franky
博客园 - 叶小钗
T
Tailwind CSS Blog

博客园 - zqzdong

word 宏(图片锐度和对比度) Maven父子结构的项目依赖使用以及打包依赖 在linux下执行不带主函数的jar Maven项目打包 eclipse调用c语言类库 scala rdd的交集 差集 并集 cdh 的 oozie时间校准 java 调用c语言类库 java jar包代码混淆 在windows下查找java服务cup过高问题 AES 加密解密 logger日志配置 hadoop安装 flume配置及其执行命令 java批量导入数据 kafkaConsumer(从topic 拿数据存入hdfs) 自定义flume的sink mongodb3.2链接设置 在mongodb中存值,如果存在则修改,不存在插入
kafka配置及其使用
zqzdong · 2017-02-24 · via 博客园 - zqzdong
1:解压
2:在config中配置server.properties
        broker.id=1
        port=9092
        host.name=Master
        socket.send.buffer.bytes=1048576
        socket.receive.buffer.bytes=1048576
        socket.request.max.bytes=104857600
        log.dir=./kafka-logs
        num.partitions=10
        zookeeper.connect=Master:2181
3:启动zookeeper:
        在bin下执行:zkServer.sh start
4:在kafka目录下;
            1):启动kafka服务      bin/kafka-server-start.sh config/server.properties
             2) :创建主题:   bin/kafka-topics.sh --create --zookeeper Master:2181 --replication-factor 1 --partitions 1 --topic test
             3): 发送主题:bin/kafka-console-producer.sh --broker-list Master:9092 --topic test
             4):  接受主题: bin/kafka-console-consumer.sh --zookeeper Master:2181 --topic test --from-beginning

posted @ 2017-02-24 16:07  zqzdong  阅读(318)  评论()    收藏  举报