Re: [VOTE] Release Apache Camel K 1.9.1 and Camel-Kamelets 0.8.1
Thanks all, This vote passes with 3 +1 binding votes and 2 +1 non-binding votes. Thanks. -- Andrea Cosentino -- Apache Camel PMC Chair Apache Karaf Committer Apache Servicemix PMC Member Email: ancosen1...@yahoo.com Twitter: @oscerd2 Github: oscerd On Tuesday, May 10, 2022, 08:55:00 AM GMT+2, Gerald Kallas wrote: +1 > Jean-Baptiste Onofré hat am 10.05.2022 08:27 geschrieben: > > > +1 (binding) > > Regards > JB > > On Mon, May 9, 2022 at 2:42 PM Andrea Cosentino wrote: > > > > Hello all: > > > > This is a combined vote to release Apache Camel K 1.9.1 and Kamelets 0.8.1. > > > > This is a patch release fixing an issue with OLM installation and a little > > bug on the AWS Kinesis source Kamelet. > > > > Kamelets release files: > > https://dist.apache.org/repos/dist/dev/camel/camel-kamelets/0.8.1/ > > Kamelets staging repository: > > https://repository.apache.org/content/repositories/orgapachecamel-1436 > > Kamelets Tag: > > https://gitbox.apache.org/repos/asf?p=camel-kamelets.git;a=shortlog;h=refs/tags/v0.8.1 > > > > Camel K release files: > > https://dist.apache.org/repos/dist/dev/camel/camel-k/1.9.1/ > > Camel K Tag: > > https://gitbox.apache.org/repos/asf?p=camel-k.git;a=shortlog;h=refs/tags/v1.9.1 > > > > Staging container image repository: > > https://hub.docker.com/r/camelk/camel-k/tags > > > > It's possible to install all staging artifacts with a single command: > > > > kamel install --operator-image=camelk/camel-k:1.9.1 --maven-repository= > > https://repository.apache.org/content/repositories/orgapachecamel-1436 > > --olm=false > > > > Please test this release candidate and cast your vote. > > > > [ ] +1 Release the binary as Apache Camel K 1.9.1 and Apache Camel Kamelets > > 0.8.1 > > [ ] -1 Veto the release (provide specific comments) > > > > The vote is open for at least 72 hours. > > > > Here's my +1. > > > > Thanks, > > Andrea Cosentino
RE: Re: Camel kafka connector - azure blob storage sink
Looking for 2 things mainly : 1 - no specific property for this one but wanted to check if we could customize the aggregation / partitioning of the messages like this connector : https://docs.confluent.io/kafka-connect-azure-blob-storage-sink/current/overview.html#partitioning-records-into-az-blob-storage-objects with properties like camel.sink.endpoint.blobName and camel.sink.endpoint.fileDir 2 - this is the main issue we have, we wanted to see if we could use an alternative way of authenticating to the storage account (mostly interested in azure AD) : https://docs.microsoft.com/en-us/rest/api/storageservices/authorize-requests-to-azure-storage I wanted to test if we could do that by injecting a service client using *camel.sink.endpoint.serviceClient*. Thanks ! On 2022/05/12 07:42:06 Claus Ibsen wrote: > Hi > > Yes the 1.x model is what we goes forward with. > > The CKC are based on Kamelets > https://camel.apache.org/camel-kamelets/0.8.x/ > > What options are you looking for? > > > On Thu, May 12, 2022 at 8:59 AM Arcand, Jean wrote: > > > > Greetings, > > > > We have a use case where we want to copy kafka messages to an azure blob container, the camel kafka connector project seemed like a really good fit. > > > > The connector which we were interested in is this one : https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-0.11.x/connectors/camel-azure-storage-blob-kafka-connector (from 0.11). It exposes properties which we were interested in using but somehow it seems like it got replaced by that one in 1.xx : https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-1.0.x/connectors/camel-azure-storage-blob-sink-kafka-connector/src/main which only supports a subset of the properties. > > > > I want to know if the target is to use the 1.xx version and eventually support more properties in the future? > > > > Thanks ! > > > > Jean > > > > > > > > > > > > > -- > Claus Ibsen > - > http://davsclaus.com @davsclaus > Camel in Action 2: https://www.manning.com/ibsen2 >
Re: [HEADS UP] - Stream Caching default enabled in Camel 3.17 onwards
Wow, good step. One of the first thing what I did with a new Camel App was enable stream caching, however was always a bit worried about the edge cases. Good they are tackled now. Raymond On Wed, May 11, 2022 at 12:57 PM Claus Ibsen wrote: > Hi > > Okay so I am working on correcting some unit tests that now fails due > to enabling stream caching. > This is good as it has also identified a few components that did not > work to well with stream caching. > > Now this works better whether or not you have enabled stream caching. > > On Tue, May 10, 2022 at 3:16 PM Claus Ibsen wrote: > > > > Hi > > > > JIRA: https://issues.apache.org/jira/browse/CAMEL-18087 > > > > Just want to let you know that we are working on enabling stream > > caching by default from 3.17 onwards. > > > > We have too many Camel users that get "tripped" by "message body is > > empty" or "message is not routed correctly" in my choice EIP, and so > > on. > > > > A FAQ on the website is not good enough in 2022 - it may be in 2007 ;) > > https://camel.apache.org/manual/faq/why-is-my-message-body-empty.html > > > > This should allow Camel also to work better for new users, especially > > with trends of new users to Camel or users that are looking at > > low-code integration. > > > > We have something great coming with the Camel JBang effort. More to > follow soon. > > > > > > -- > > Claus Ibsen > > - > > http://davsclaus.com @davsclaus > > Camel in Action 2: https://www.manning.com/ibsen2 > > > > -- > Claus Ibsen > - > http://davsclaus.com @davsclaus > Camel in Action 2: https://www.manning.com/ibsen2 >
Re: unmarshalling with jackson, LocalDateTime and datatype:jackson-datatype-jsr310
Hello, you have to register the module. For example: final JacksonDataFormat df = new JacksonDataFormat(MyPojo.class); df.setObjectMapper(new ObjectMapper().registerModule(new JavaTimeModule())); Regards On Thu, 2022-05-12 at 10:19 +0300, Vyacheslav Boyko wrote: > Hello! > > How to get managed with such problem? > > I need to unmarshall incoming from Kafka data into POJO having one > field > of LocalDateTime type. > > I have the route: > > from(parametersProvider.getEventsListeningEndpoint()) > .unmarshal().json(EventDto.class) > > And it produces the exception: > > com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Java 8 > date/time type `java.time.LocalDateTime` not supported by default: > add > Module "com.fasterxml.jackson.datatype:jackson-datatype-jsr310" to > enable handling > > I have these dependencies > > implementation group: 'com.fasterxml.jackson.datatype', name: > 'jackson-datatype-jsr310', version: '2.12.4' > > implementation group: 'org.apache.camel.springboot', name: > 'camel-jackson-starter', version: '3.15.0' > > implementation group: 'org.apache.camel', name: 'camel-jackson', > version: '3.15.0' > implementation group: 'org.apache.camel', name: 'camel- > jacksonxml', > version: '3.15.0' > > but they seem don't work in this case. > > How to deal with it? >
Re: Camel kafka connector - azure blob storage sink
Hi Yes the 1.x model is what we goes forward with. The CKC are based on Kamelets https://camel.apache.org/camel-kamelets/0.8.x/ What options are you looking for? On Thu, May 12, 2022 at 8:59 AM Arcand, Jean wrote: > > Greetings, > > We have a use case where we want to copy kafka messages to an azure blob > container, the camel kafka connector project seemed like a really good fit. > > The connector which we were interested in is this one : > https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-0.11.x/connectors/camel-azure-storage-blob-kafka-connector > (from 0.11). It exposes properties which we were interested in using but > somehow it seems like it got replaced by that one in 1.xx : > https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-1.0.x/connectors/camel-azure-storage-blob-sink-kafka-connector/src/main > which only supports a subset of the properties. > > I want to know if the target is to use the 1.xx version and eventually > support more properties in the future? > > Thanks ! > > Jean > > > > > -- Claus Ibsen - http://davsclaus.com @davsclaus Camel in Action 2: https://www.manning.com/ibsen2
unmarshalling with jackson, LocalDateTime and datatype:jackson-datatype-jsr310
Hello! How to get managed with such problem? I need to unmarshall incoming from Kafka data into POJO having one field of LocalDateTime type. I have the route: from(parametersProvider.getEventsListeningEndpoint()) .unmarshal().json(EventDto.class) And it produces the exception: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Java 8 date/time type `java.time.LocalDateTime` not supported by default: add Module "com.fasterxml.jackson.datatype:jackson-datatype-jsr310" to enable handling I have these dependencies implementation group: 'com.fasterxml.jackson.datatype', name: 'jackson-datatype-jsr310', version: '2.12.4' implementation group: 'org.apache.camel.springboot', name: 'camel-jackson-starter', version: '3.15.0' implementation group: 'org.apache.camel', name: 'camel-jackson', version: '3.15.0' implementation group: 'org.apache.camel', name: 'camel-jacksonxml', version: '3.15.0' but they seem don't work in this case. How to deal with it? -- Vyacheslav Boyko mailto:mail4...@gmail.com
Camel kafka connector - azure blob storage sink
Greetings, We have a use case where we want to copy kafka messages to an azure blob container, the camel kafka connector project seemed like a really good fit. The connector which we were interested in is this one : https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-0.11.x/connectors/camel-azure-storage-blob-kafka-connector (from 0.11). It exposes properties which we were interested in using but somehow it seems like it got replaced by that one in 1.xx : https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-1.0.x/connectors/camel-azure-storage-blob-sink-kafka-connector/src/main which only supports a subset of the properties. I want to know if the target is to use the 1.xx version and eventually support more properties in the future? Thanks ! Jean
