消费者

消费者和消费组消费者消费组消费者和消费组消费者负责订阅topic的主题，从订阅的主题中拉取poll消息消费组每个消费者都只有一个消费组对应，一个消费组的消费者实例可以在不同机器上。当消息主题被订阅后，只会被投递给订阅的消费组中的一个消费者上图一个kafka集群有2个broker server1和se

生产者

cilent代码cilent代码public class KafkaProducerAnalysis { /** * 生产者逻辑 * 1。配置生产者客户端参数及创建相应的生产者实例 * 2。构建待发送消息 * 3。发送消息 * 4。关闭生产者实例

初识KafKa

分布式流式处理平台、高吞吐、可持久化、水平扩展、支持流数据处理消息系统系统解耦、冗余存储、流量削峰、缓冲、异步通信、扩展性、可恢复性、消息顺序性、回溯消费存储系统消息持久化功能、多副本机制、可作为长期的数据存储系统使用流式处理平台完整的流式处理类库、窗口、连接、聚合等Kafka