Have you checked the firewall setting on vm/host? On Thu, Jan 21, 2016, 10:29 AM BYEONG-GI KIM <bg...@bluedigm.com> wrote:
> Hello. > > I packaged it to an executable jar file and executed it on the VM, and > yes, it was successfully worked. > > I'm really confuse why it didn't work on my Windows10 environment where is > on the host environment and worked well on the VM environment... It is > weird indeed. > > 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 >>>> > >>>> >>> >>> >>> >>> -- >>> (주)비디 클라우드사업부 와이즈본부 클라우드기술팀 선임 >>> >> > > > -- > (주)비디 클라우드사업부 와이즈본부 클라우드기술팀 선임 >
