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) 发送数据的方式:同步和异步