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