kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chia-Chun Shih <chiachun.s...@gmail.com>
Subject Re: Issues Running Kafka Producer Java example
Date Sun, 16 Nov 2014 00:32:34 GMT
Please check your consumer's position

http://kafka.apache.org/documentation.html#basic_ops_consumer_lag


2014-11-16 7:09 GMT+08:00 Stream Processing <smarty.juice@gmail.com>:

> anyone?
>
> On Sat, Nov 8, 2014 at 4:25 PM, Hardik Pandya <smarty.juice@gmail.com>
> wrote:
>
> > 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();
> >  }
> >
> > }
> >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message