java代碼之kakfa生產(chǎn)者簡(jiǎn)單介紹

這篇文章主要講解了“java代碼之kakfa生產(chǎn)者簡(jiǎn)單介紹”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“java代碼之kakfa生產(chǎn)者簡(jiǎn)單介紹”吧！

Kafka原理圖

JAVA源代碼之kafka生產(chǎn)者，本次客戶端使用kafka的console命令行，消費(fèi)，生產(chǎn)者使用代碼編碼。看了好多生產(chǎn)者代碼都帶有props.put("zk.connect", "n2:2181/jafka");  真是感到不解，沒(méi)有這個(gè)參數(shù)也可以運(yùn)行的好好的，實(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<String, String> producer = new Producer<String, String>(config); 
        KeyedMessage<String, String> keyedMessage = new KeyedMessage<String, String>(topicName, data); 
        producer.send(keyedMessage);
        producer.close(); 
    } 
} 

MAVEN環(huán)境

<dependencies>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka_2.10</artifactId>
            <version>0.9.0.1</version>
            <exclusions>
                <exclusion>
                    <artifactId>jmxtools</artifactId>
                    <groupId>com.sun.jdmk</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jmxri</artifactId>
                    <groupId>com.sun.jmx</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jms</artifactId>
                    <groupId>javax.jms</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.15</version>
            <exclusions>
                <exclusion>
                    <artifactId>jmxtools</artifactId>
                    <groupId>com.sun.jdmk</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jmxri</artifactId>
                    <groupId>com.sun.jmx</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jms</artifactId>
                    <groupId>javax.jms</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>mail</artifactId>
                    <groupId>javax.mail</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
    </dependencies>

實(shí)踐截圖

啟動(dòng)zk

感謝各位的閱讀，以上就是“java代碼之kakfa生產(chǎn)者簡(jiǎn)單介紹”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)java代碼之kakfa生產(chǎn)者簡(jiǎn)單介紹這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！