Re: SamzaContainer NullPointerException for read byte[] topic from Kafka

2015-10-15 Thread Selina Tech
Hi, Yi: Thanks for your suggestion. I found the bug. the line of logger.info got Exception. Thanks a lot! Sincerely, Selina On Thu, Oct 15, 2015 at 10:03 AM, Yi Pan wrote: > Hi, Selina, > > Your stack trace showed that the exception was thrown at line 50 in your > task code. Could y

Re: SamzaContainer NullPointerException for read byte[] topic from Kafka

2015-10-15 Thread Yi Pan
Hi, Selina, Your stack trace showed that the exception was thrown at line 50 in your task code. Could you point out which line is it? It would be helpful if you can add some log info regarding to the message you receive in the process() vs the message you read from Kafka console consumer. Thanks

SamzaContainer NullPointerException for read byte[] topic from Kafka

2015-10-14 Thread Selina Tech
Dear All: I tried to consumer kafka topic "cnr-proto" in Java. It got the SamzaContainer NullPointerException as below. The messages can be shown by command line correctly "deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic cnr-proto" My Key