0
点赞
收藏
分享

微信扫一扫

Kafka的核心概念

1. message 消息

Flume中传递数据的单位:Event

Storm中传递数据的单位:Tuple

Kafka中传递数据的单位:Message

数据存储和通信的基本单位

每个生产者可以向一个Topic发布一些message

如果消费者订阅相关Topic的数据,数据发布后,新添加的message被广播给消费者

2. producer 生产者

向broker发送消息

通过zk定位到所有的broker(只需要向一个broker中生产数据)

发送数据的方式: 同步和异步:producer.properties 批发送: 一批一批的发送,减少网络连接的开销 数据源 数据源可以由多种类型的角色来扮演:flume,service,web app ,font project... ... 向broker发送消息,只需要指定一个broker(zk自动定位到其他的broker) 发送数据的方式:同步和异步

举报

相关推荐

0 条评论