java NullPointer exception in NotifyBuilder with camel-kafka component

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(MessageAndMeta

Re: java NullPointer exception in NotifyBuilder with camel-kafka component

Thanks. I'll submit a patch for this. On Mon, Jun 22, 2015 at 11:40 PM, Claus Ibsen 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 wrote: &g

[Camel-kafka] KafkaProducer causes camel route to loop infinitely

The KafkaProducer class reads the topic name from exchange headers. This causes a problem when the route ends with a "to" endpoint since in this case, the exchange still has its header set to the "from" endpoint's topic. See my comments in https://issues.apache.org/jira/browse/CAMEL-7331 Thanks,

[Camel-Kafka] consumerStreams vs ConsumersCount

Hi, Can someone explain the difference between consumerStreams and ConsumersCount properties in the Kafka adapter? Thanks, Rahul

Re: java NullPointer exception in NotifyBuilder with camel-kafka component

Created a jira and submitted patch for this bug - https://issues.apache.org/jira/browse/CAMEL-8908 On Tue, Jun 23, 2015 at 8:48 AM, Rahul Jain wrote: > Thanks. I'll submit a patch for this. > > On Mon, Jun 22, 2015 at 11:40 PM, Claus Ibsen > wrote: > >> Hi >&g

Re: [Camel-kafka] KafkaProducer causes camel route to loop infinitely

> in JMS, if people want to send to a destination based on a header. > > On Wed, Jun 24, 2015 at 7:51 PM, Rahul Jain wrote: > > The KafkaProducer class reads the topic name from exchange headers. This > > causes a problem when the route ends with a "to" endpoint since i

[Camel-Kafka] Value of KafkaConstants.KEY constant

In KafkaConstants, the constant "KEY" is declared as * public static final String KEY = "kafka.CONTENT_TYPE";* This is used to store the kafka message key in exchange. But why do we refer to it as CONTENT_TYPE here?