Kafka基礎-生產者發送消息

不管你是使用Kafka做爲隊列,消息總線仍是數據存儲平臺,你都會用到生產者,用於發送數據到Kafka。下文介紹如何使用Java來發送消息到Kafka。 1. 發送消息的主要步驟 java 首先建立ProducerRecord對象,此對象除了包括須要發送的數據value以外還必須指定topic,另外也能夠指定key和分區。當發送ProducerRecord的時候,生產者作的第一件事就是把key和va
相關文章
相關標籤/搜索