Hello Champs, I am trying to run first java producer example.
Upon running this example, producer successfully sends the message, at least it looks like it does, there is no java dump But trying to verify the messages on consumer side - it does not return any data sent by producer https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example here's my Producer code - thanks in advance! package example.kafka; import java.util.Date; import java.util.Properties; import java.util.Random; import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; public class TestProducer { /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub long events = Long.parseLong(args[0]); Properties props = new Properties(); props.put("metadata.broker.list", "10.0.2.15:9092,10.0.2.15:9093, 10.0.2.15:9094,10.0.2.15:9095"); props.put("serializer.class", "kafka.serializer.StringEncoder"); props.put("partitioner.class", "example.kafka.SimplePartitioner"); props.put("request.required.acks", "1"); ProducerConfig config = new ProducerConfig(props); Producer<String, String> producer = new Producer<String, String>(config); Random rnd = new Random(); for(long event=0;event < events;event++) { Long runtime = new Date().getTime(); String msgKey= "192.168.2." + rnd.nextInt(255); String msg = runtime + ",www.exmaple.com," + msgKey; KeyedMessage<String, String> data = new KeyedMessage<String, String>("page_visits", msgKey, msg); producer.send(data); System.out.println("message sent"); } producer.close(); } }
