Kafa核心属性1

2017-08-11  本文已影响25人  Tango_520f

1.Kafka的消息可以基于key值指定partition,每个partition在物理上对应一个文件夹;

2.针对Consumer high level API时,同一Topic的一条消息只能被同一个Consumer Group内的一个Consumer消费,但多个Consumer Group可同时消费这一消息。

3.kafka的topic的消息广播:发送给所有的Consumer    kafka的topic的消息单拨:发送给单一的consumer;

4.ConsumerGroup可以将Consumer进行自由的分组,基于不同的ConsumerGroup中的Consumer可以同时消费一条消息,应用可拓展为离线数据处理,在线实时处理,数据备份同时处理,只要保证三者的Consumer在不同的ConsumerGroup中;

【实时流处理系统Storm,离线数据批处理系统Hadoop,数据备份至数据中心】

5.

上一篇下一篇

猜你喜欢

热点阅读