java代码之kakfa生产者简单介绍

这篇文章主要讲解了“java代码之kakfa生产者简单介绍”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“java代码之kakfa生产者简单介绍”吧！

创新互联主要从事成都做网站、网站建设、外贸营销网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务芮城,十多年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:028-86922220

Kafka原理图

JAVA源代码之kafka生产者，本次客户端使用kafka的console命令行，消费，生产者使用代码编码。看了好多生产者代码都带有props.put("zk.connect", "n2:2181/jafka");  真是感到不解，没有这个参数也可以运行的好好的，实践出真知，弄懂原理真的很重要，具体如下：

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 producer = new Producer(config); 
        KeyedMessage keyedMessage = new KeyedMessage(topicName, data); 
        producer.send(keyedMessage);
        producer.close(); 
    } 
} 

MAVEN环境

       
            org.apache.kafka
            kafka_2.10
            0.9.0.1
           
               
                    jmxtools
                    com.sun.jdmk
               
               
                    jmxri
                    com.sun.jmx
               
               
                    jms
                    javax.jms
               
           
       
       
            log4j
            log4j
            1.2.15
           
               
                    jmxtools
                    com.sun.jdmk
               
               
                    jmxri
                    com.sun.jmx
               
               
                    jms
                    javax.jms
               
               
                    mail
                    javax.mail
               
           
       
       
            junit
            junit
            4.11
            test
       
   

实践截图

启动zk

感谢各位的阅读，以上就是“java代码之kakfa生产者简单介绍”的内容了，经过本文的学习后，相信大家对java代码之kakfa生产者简单介绍这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！