kafka

window=kafka+zk

伺服器 類别 實體

broker topic partition

1/n partition

producer-->broker-->consumer group

kafkatemplate.send(topic,msg)

@kafkalistener(topics = {"topic"})