window=kafka+zk 服务器 类别 物理 broker Topic Partition 1/n Partition
Producer-->broker-->Consumer Group
KafkaTemplate.send(Topic,msg) @KafkaListener(topics = {"Topic"})