kafka

window=kafka+zk

服务器 类别 物理

broker topic partition

1/n partition

producer-->broker-->consumer group

kafkatemplate.send(topic,msg)

@kafkalistener(topics = {"topic"})