Thanks. I'll submit a patch for this. On Mon, Jun 22, 2015 at 11:40 PM, Claus Ibsen <claus.ib...@gmail.com> wrote:
> Hi > > Yeah well spotted. You are welcome to log a JIRA and work on a patch / PR > http://camel.apache.org/support > > On Mon, Jun 22, 2015 at 7:29 PM, Rahul Jain <rahul...@gmail.com> wrote: > > Camel-kafka component (2.15.1) gives a NullPointer exception in > > NotifyBuilder causing our assertions to fail. > > > > The error seems to be due to the fact that the Exchange created by the > > component has fromEndPoint set to null. > > > > In KafkaEndpoint.java > > > > public Exchange createKafkaExchange(MessageAndMetadata<byte[], byte[]> > > mm) { > > Exchange exchange = new DefaultExchange(getCamelContext(), > > getExchangePattern()); > > > > I believe this should be instantiated as > > Exchange exchange = new DefaultExchange(this, getExchangePattern()); > > > > > > -rahul > > > > -- > Claus Ibsen > ----------------- > Red Hat, Inc. > Email: cib...@redhat.com > Twitter: davsclaus > Blog: http://davsclaus.com > Author of Camel in Action: http://www.manning.com/ibsen > hawtio: http://hawt.io/ > fabric8: http://fabric8.io/ >
