kafka java客户端编程 -尊龙游戏旗舰厅官网

---

kafka_2.10-0.8.1.1

---

maven

　　
　　　　org.apache.kafka
　　　　kafka_2.10
　　　　0.8.1.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
　　

---

producer

 

1 package org.admln.kafka.test; 2 3 import java.util.properties; 4 5 import kafka.javaapi.producer.producer; 6 import kafka.producer.keyedmessage; 7 import kafka.producer.producerconfig; 8 9 public class producertest { 10 11 public static void main(string[] args) { 12 properties props = new properties(); 13 //props.put("zk.connect", "192.168.1.110:2181"); 14 // serializer.class为消息的序列化类 15 props.put("serializer.class", "kafka.serializer.stringencoder"); 16 // 配置metadata.broker.list, 为了高可用, 最好配两个broker实例 17 props.put("metadata.broker.list", "192.168.1.113:9092"); 18 // 设置partition类, 对队列进行合理的划分 19 //props.put("partitioner.class", "idoall.testkafka.partitionertest"); 20 // ack机制, 消息发送需要kafka服务端确认 21 props.put("request.required.acks", "1"); 22 23 props.put("num.partitions", "2"); 24 producerconfig config = new producerconfig(props); 25 producer producer = new producer(config); 26 for (int i = 0; i < 10; i ) 27 { 28 string msg = "hello" i; 29 producer.send(new keyedmessage("test",msg)); 30 system.out.println("i:" i " msg:" msg); 31 } 32 } 33 }

---

 consumer

 运行consumer一直接收不到消息，还没找到原因

---

 

转载于:https://www.cnblogs.com/admln/p/kafka-javaclient-program.html

总结

以上是尊龙游戏旗舰厅官网为你收集整理的kafka java客户端编程的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得尊龙游戏旗舰厅官网网站内容还不错，欢迎将尊龙游戏旗舰厅官网推荐给好友。