Re: Camel Kafka Component / feature request: batch producer with individual headers

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,

RE: Re: Camel Kafka Component / feature request: batch producer with individual headers

[CAMEL-18527] Camel Kafka Component: batch producer with individual headers - ASF JIRA 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. > > > On Mon, Sep 19, 2022

Re: Camel Kafka Component / feature request: batch producer with individual headers

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

Re: Camel Kafka Component as a Consumer within a Route

Hello, Yes. Thank you. We are able to do this with PollEnrich. The following route is modified: from("timer://foo?fixedRate=true&period=1") .setBody().constant("test") .setHeader("kafka.OFFSET",constant("smallest"))

Re: Camel Kafka Component as a Consumer within a Route

See the content enricher EIP and the pollEnrich On Wed, Dec 23, 2015 at 1:51 PM, web_nab...@sunilsamuel.com wrote: > Hello, > > I am trying to use the kafka component as a consumer from within a route. > For instance, > > from("timer://foo?fixedRate=true&period=6") >

Re: Camel-Kafka Component

Thanks for the answer. On the Apache Camel page I see for both releases 2.16.0 and 2.15.3 a planned release date of Q3 2015. Do you have already a more precise date for any of the two? Regards, Christian Mark Mindenhall [via Camel] schrieb am Di., 21. Juli 2015 um 03:13 Uhr: > Hi Christian, > >

Re: Camel-Kafka Component

Hi Christian, The patch Claus referenced was also applied to the 2.15.x branch, so it will be part of the 2.15.3 release as well (if you’d prefer to avoid using snapshot builds). Best, Mark On July 20, 2015 at 6:02:47 AM, Claus Ibsen (claus.ib...@gmail.com) wrot

Re: Camel-Kafka Component

Hi The upcoming Camel 2.16 should support different encoders so you can use binary etc. You 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 wrote: > He

Re: Camel-Kafka Component

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: http://camel.4654

Re: Camel-Kafka Component

I am answering my own question - Looks like we have to explicitly specify the serializerClass for the producer like this from("direct:testingKafka").to("kafka:localhost:9092?topic=test&serializerClass=kafka.serializer.StringEncoder") This worked. Would be nice if it is handled in Camel if poss

Re: Camel-Kafka Component

I've tried to give the kafka component a whirl (disclaimer - I am new to both camel and kafka). Tried this and got this exception when sending a message to kafka In my spring class that produces: @Autowired private ProducerTemplate template; public void sendKakfaMessage(Integer id){

Re: Camel-Kafka Component

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 patch

Re: Camel-Kafka Component

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 patch

Re: Camel-Kafka Component

Hi Richard, Thanks for your kind response, I will proceed adding documentation as for CAMEL-7288 as well. Thanks On Sun, Mar 30, 2014 at 9:18 AM, Richard Kettelerij < richardkettele...@gmail.com> wrote: > As Claus mentioned it would be great if you could improve the recently > added camel-kaf

Re: Camel-Kafka Component

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 > Camel 2.13.0. > http

Re: Camel-Kafka Component

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://richar

Re: Camel-Kafka Component

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, > > I was recentl