Dear Steve Could you tell me what kafka version you are using for the source code's package?
I included the kafka library from maven repository ( http://mvnrepository.com/artifact/org.apache.kafka), and the artifactId is kafka_2.11 and version is 0.9.0.0. The link is as below: http://mvnrepository.com/artifact/org.apache.kafka/kafka_2.11/0.9.0.0 The maven dependency is as below: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>0.9.0.0</version> </dependency> Are you using this version? Best regards Kim 2016-01-20 18:14 GMT+09:00 Steve Tian <steve.cs.t...@gmail.com>: > 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 >>> > >>> >> >> >> >> -- >> (주)비디 클라우드사업부 와이즈본부 클라우드기술팀 선임 >> > -- (주)비디 클라우드사업부 와이즈본부 클라우드기술팀 선임
