Spark Streaming实时流处理项目实战笔记——Kafka单节点单broker的部署及使用
本文共 648 字，大约阅读时间需要 2 分钟。
Kafka的核心概念
consumer 消费者 producter 生产者 broker 经纪人 topic 主题
Kafka依赖于zookeeper
1、安装zookeeper，略
2、启动zookeeper zkServer.sh start
3、zkCli.sh 连接zookeeper （2181端口）
Connecting to localhost:2181
启动kafka
kafka-server-start.sh -daemon /opt/kafka/kafka/config/server.properties
创建Topic
replication复制 factor 因数因子
kafka-topics.sh --create --zookeeper hadoop:2181 --replication-factor 3 --partitions 3 --topic hello
发送消息
kafka-console-producer.sh --broker-list hadoop2:9092 --topic yes
>hello world
消费消息
kafka-console-consumer.sh --bootstrap-server hadoop:9092 --from-beginning --topic yes
查看Topic详细信息
kafka-topics.sh --describe --zookeeper hadoop:2181 --topic yes
转载地址：http://dtazi.baihongyu.com/
你可能感兴趣的文章
牛客练习赛51，D（二分图匹配）
查看>>
POJ2892，Tunnel Warfare（线段树维护连续区间）
查看>>
POJ3468,A Simple Problem with Integers（线段树-区间查询-区间更新）
查看>>
快速幂（递归）
查看>>
CodeForces 1101A Minimum Integer（思维）
查看>>
CodeForces 1102A Integer Sequence Dividing（思维）
查看>>
CodeForces 1087B Div Times Mod（思维）
查看>>
杭电ACM——4310，Hero（贪心）
查看>>
杭电ACM——1789，Doing Homework Again（贪心）
查看>>
北大ACM——2782，Bin Packing（贪心）
查看>>
北大ACM——4014，Dice（贪心）
查看>>
杭电ACM——4864，Task（贪心）
查看>>
北大ACM——3176，Cow Bowling（动态规划）
查看>>
北大ACM——2229，Sumsets（DP或思维）
查看>>
北大ACM——3186，Treats For The Cows（DP）
查看>>
杭电ACM——蝎子搬新家（贪心）
查看>>
杭电ACM——处理木棍（贪心）
查看>>
杭电ACM——broomstick训练营（贪心）
查看>>
杭电ACM——1018，Big Number（思维）
查看>>
杭电ACM——6463（思维）
查看>>