java代碼之kakfa生產(chǎn)者簡單介紹
這篇文章主要講解了“java代碼之kakfa生產(chǎn)者簡單介紹”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“java代碼之kakfa生產(chǎn)者簡單介紹”吧！
創(chuàng)新互聯(lián)主要從事成都做網(wǎng)站、網(wǎng)站建設(shè)、外貿(mào)營銷網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)芮城,十多年網(wǎng)站建設(shè)經(jīng)驗,價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):028-86922220
Kafka原理圖
JAVA源代碼之kafka生產(chǎn)者，本次客戶端使用kafka的console命令行，消費，生產(chǎn)者使用代碼編碼?？戳撕枚嗌a(chǎn)者代碼都帶有props.put("zk.connect", "n2:2181/jafka"); 真是感到不解，沒有這個參數(shù)也可以運行的好好的，實踐出真知，弄懂原理真的很重要，具體如下：
import java.util.Properties;
import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
/**
* 0.7.2
* @author Administrator
*
*/
public class ProducerSample {
public static void main(String[] args) {
String topicName = "test";
String data = "this is a java-test. i Am gaojs";
ProducerSample ps = new ProducerSample();
Properties props = new Properties();
props.put("metadata.broker.list", "192.168.1.101:9092");
props.put("serializer.class", "kafka.serializer.StringEncoder");
props.put("request.required.acks","1");
ProducerConfig config = new ProducerConfig(props);
Producer
KeyedMessage
producer.send(keyedMessage);
producer.close();
}
}
MAVEN環(huán)境
實踐截圖
啟動zk
感謝各位的閱讀，以上就是“java代碼之kakfa生產(chǎn)者簡單介紹”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對java代碼之kakfa生產(chǎn)者簡單介紹這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！
文章名稱：java代碼之kakfa生產(chǎn)者簡單介紹
轉(zhuǎn)載來于：http://m.jiaotiyi.com/article/pohogp.html