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

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

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生产者简单介绍这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是，小编将为大家推送更多相关知识点的文章，欢迎关注！