SparkStreaming部分:kafka的总结【文字说明+图片展示+各种命令】

Kafka的架构:分布式消息系统,默认将消息存入磁盘,存储时间是7天。 Producer:消息的生产者,自己决定消息写往哪个partition,两种:1.hash,2.轮询 Broker:组建kafka集群的节点,broker之间没有主从关系,broker由zookeeper来协调,broker负责消息的读写,存储。每个broker可以管理多个partition。 Topic:一类消息的总称/消息
相关文章
相关标签/搜索