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.
网友评论