Your code works in my environment. Are you able to run your producer code inside your vm? You can also debug via changing the log level to DEGUG/TRACE.
Cheers, Steve On Wed, Jan 20, 2016, 4:30 PM BYEONG-GI KIM <bg...@bluedigm.com> wrote: > Sure, I started consumer before starting and sending messages from > producer, and my broker version, if you mean the kafka version, is 0.9.0. > > Best regards > > Kim > > 2016-01-20 17:28 GMT+09:00 Steve Tian <steve.cs.t...@gmail.com>: > >> Did you start your consumer before sending message? Broker version? >> >> Cheers, Steve >> >> On Wed, Jan 20, 2016, 3:57 PM BYEONG-GI KIM <bg...@bluedigm.com> wrote: >> >> > Hello. >> > >> > I set up the Kafka testbed environment on my VirtualBox, which simply >> has a >> > Kafka broker. >> > >> > I tested the simple consumer & producer scripts, aka >> > kafka-console-consumer.sh and bin/kafka-console-producer.sh >> respectively, >> > and both of them worked fine. I could see the output from the consumer >> side >> > whenever typing any words on the producer. >> > >> > After that, I moved to test a simple java kafka producer/consumer. I >> copied >> > and pasted the example source code for producer from >> > >> > >> http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html >> > , >> > and yeah, unfortunately, it seems not working well; no output was >> printed >> > by the above consumer script. There was even no error log on Eclipse. >> > >> > I really don't know what the problem is... I think that the properties >> for >> > both zookeeper and kafka seems fine, since the example scripts worked >> well, >> > at least. >> > >> > I attached my tested source code: >> > ====================================================================== >> > import java.util.Properties; >> > >> > import org.apache.kafka.clients.producer.KafkaProducer; >> > import org.apache.kafka.clients.producer.Producer; >> > import org.apache.kafka.clients.producer.ProducerRecord; >> > import org.apache.kafka.common.KafkaException; >> > import org.apache.kafka.common.errors.TimeoutException; >> > >> > public class ProducerExample { >> > public static void main(String[] args) throws Exception, >> TimeoutException, >> > KafkaException { >> > Properties props = new Properties(); >> > props.put("bootstrap.servers", "10.10.0.40:9092"); >> > props.put("acks", "all"); >> > props.put("retries", 0); >> > props.put("batch.size", 16384); >> > // props.put("linger.ms", 1); >> > props.put("buffer.memory", 33554432); >> > props.put("key.serializer", >> > "org.apache.kafka.common.serialization.StringSerializer"); >> > props.put("value.serializer", >> > "org.apache.kafka.common.serialization.StringSerializer"); >> > >> > Producer<String, String> producer = new KafkaProducer<String, >> > String>(props); >> > >> > try { >> > for (int i = 0; i < 10; i++) { >> > producer.send(new ProducerRecord<String, String>("test", 0, >> > Integer.toString(i), Integer.toString(i))); >> > } >> > } catch (TimeoutException te) { >> > System.out.println(te.getStackTrace()); >> > te.getStackTrace(); >> > } catch (Exception ke) { >> > System.out.println(ke.getStackTrace()); >> > ke.getStackTrace(); >> > } >> > >> > producer.close(); >> > } >> > } >> > ====================================================================== >> > >> > Any advice would really be helpful. Thanks in advance. >> > >> > Best regards >> > >> > Kim >> > >> > > > > -- > (주)비디 클라우드사업부 와이즈본부 클라우드기술팀 선임 >
