PR: https://github.com/apache/camel/pull/8407
> Am 19.09.2022 um 17:55 schrieb Claus Ibsen :
>
> Hi
>
> Yeah this sounds reasonable, you are welcome to create a JIRA and send a PR.
>
>
> On Mon, Sep 19, 2022 at 3:15 PM r.wiedm...@bitproquo.org <
> r.wiedm...@bitproquo.org> wrote:
>
>> Hi all,
[CAMEL-18527] Camel Kafka Component: batch producer with individual headers -
ASF JIRA <https://issues.apache.org/jira/browse/CAMEL-18527>
On 2022/09/19 15:55:01 Claus Ibsen wrote:
> Hi
>
> Yeah this sounds reasonable, you are welcome to create a JIRA and send a PR.
>
&
Hi
Yeah this sounds reasonable, you are welcome to create a JIRA and send a PR.
On Mon, Sep 19, 2022 at 3:15 PM r.wiedm...@bitproquo.org <
r.wiedm...@bitproquo.org> wrote:
> Hi all,
>
> if we look at classes KafkaProducer and KeyValueIterator, we see that it
> is possible to send a batch of kaf
Hi all,
if we look at classes KafkaProducer and KeyValueIterator, we see that it is
possible to send a batch of kafka messages,
but only with identical set of headers which is determined by the „parent“
Exchange which holds the Iterator or Iterable in its body.
In our usecase, the body contains
Github user jamesnetherton closed the pull request at:
https://github.com/apache/camel/pull/1904
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user jamesnetherton opened a pull request:
https://github.com/apache/camel/pull/1904
CAMEL-11721: Camel Kafka component JSON metadata is invalid
https://issues.apache.org/jira/browse/CAMEL-11721
You can merge this pull request into a Git repository by running:
$ git
Hi
Please ask such questions on the user mailing list instead.
On Tue, Dec 13, 2016 at 10:27 AM, Максим Козлов wrote:
> Hi,
>
> In my application use camel-kafka component as a producer and consumer.
> For example:
>
> from("kafka:...?topic=topic1")
> .process(n
Hi,
In my application use camel-kafka component as a producer and consumer.
For example:
from("kafka:...?topic=topic1")
.process(new ChangeMessage())
to("kafka:...?topic=topic2")
If change only body, producer send to topic1, because in.header this value
"kafka.TOPIC
ot;groupId=groupBatch",1000)
.log("FROM THE TIMER [${body}]")
;
Thank You,
sunil.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Kafka-Component-as-a-Consumer-within-a-Route-tp5775404p5775410.html
Sent from the Camel Development mailing list archive at Nabble.com.
it, the kafka component becomes a
> producer. Is there a way to consume from within a route?
>
> thanks,
> sunil.
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Camel-Kafka-Component-as-a-Consumer-within-a-Route-tp5775404.
=100")
.to("log:input ${body}");
But at this point, the way that I am using it, the kafka component becomes a
producer. Is there a way to consume from within a route?
thanks,
sunil.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-K
u are welcome to try 2.16-SNAPSHOT to give it a test
> spin.
>
> The commit is
>
> https://github.com/apache/camel/commit/1af2133f68498bd91361a2ca2237fb2426233721
>
> On Mon, Jul 20, 2015 at 1:58 PM, mekki20 <[hidden email]
> <http:///user/SendEmail.jtp?type=node&nod
wrote:
> Hello,
>
> I've started to use the Camel-Kafka Component but also wanted to send binary
> messages, not only String encoded ones. Attached is the changed
> KafakProducer.java file.
> I'm happy to get your feedback and how to proceed.
>
> Regards,
>
:
> Hello,
>
> I've started to use the Camel-Kafka Component but also wanted to send binary
> messages, not only String encoded ones. Attached is the changed
> KafakProducer.java file.
> I'm happy to get your feedback and how to proceed.
>
> Regards,
> Christian
>
Hello,
I've started to use the Camel-Kafka Component but also wanted to send binary
messages, not only String encoded ones. Attached is the changed
KafakProducer.java file.
I'm happy to get your feedback and how to proceed.
Regards,
Christian
--
View this message in context:
ht
t is handled in Camel if possible. I don't know enough
about it or Kafka at the moment to submit a patch. Would like feedback and
I'll see if I can bake it into a pull request.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Kafka-Component-tp5749525p5756455.ht
cer.process(KafkaProducer.java:78)
at
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:113)
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Kaf
Hi all,
Based on our earlier discussion I have gone through and submitted a patch
for the camel-kafka component.
The patch has been submitted in CAMEL-7339 (
https://issues.apache.org/jira/browse/CAMEL-7339) and I would like to
kindly ask your feedback on this.
Among the the changes the
Hi all,
Based on our earlier discussion I have gone through and submitted a patch
for the camel-kafka component.
The patch has been submitted in CAMEL-7339 (
https://issues.apache.org/jira/browse/CAMEL-7339) and I would like to
kindly ask your feedback on this.
Among the the changes the
30, 2014 at 1:43 AM, Ioannis Polyzos >wrote:
>
> > Hello all,
> >
> > I was recently working on a *camel-kafka* component that I would like to
> > contribute back to the Apache Camel project.
> >
> > The component allows to configure the majority of the k
Hi Claus,
I would be more than happy to proceed with so.
I will go through and proceed with the relevant changes in the next days.
thanks
On Sun, Mar 30, 2014 at 7:57 AM, Claus Ibsen wrote:
> Hi
>
> We recently added a new camel-kafka component which was released in
>
As Claus mentioned it would be great if you could improve the recently
added camel-kafka component (wherever possible).
The new Kafka component also missing documentation (see
https://issues.apache.org/jira/browse/CAMEL-7288), that would be also be
much appreciated.
Regards,
Richard
http
Hi
We recently added a new camel-kafka component which was released in
Camel 2.13.0.
https://github.com/apache/camel/tree/master/components/camel-kafka
You are welcome to help improve the existing component.
On Sun, Mar 30, 2014 at 1:43 AM, Ioannis Polyzos wrote:
> Hello all,
>
&
Hello all,
I was recently working on a *camel-kafka* component that I would like to
contribute back to the Apache Camel project.
The component allows to configure the majority of the kafka client
parameters and to transfer both the body and the exchange.It definitely
need more work and
24 matches
Mail list logo
