Re: [VOTE] Release Apache Camel K 2.3.2
+1 non binding Em ter., 21 de mai. de 2024 às 11:10, Pasquale Congiusti escreveu: > > Hello, > > This is a vote to release Apache Camel K 2.3.2. This release provides some > bug fixes reported in the latest release 2.3.2 [1] due to certain > regressions introduced in version 2.3.1. > > Camel K release files: > https://dist.apache.org/repos/dist/dev/camel/camel-k/2.3.2/ > > Camel K Tag: > https://github.com/apache/camel-k/releases/tag/v2.3.2 > > Camel K CRD Java dependency staging repository: > https://repository.apache.org/content/repositories/orgapachecamel-1713/ > > Staging container image repository (multi architecture manifest): > https://hub.docker.com/layers/camelk/camel-k/2.3.2/images/sha256-8d8f86bdedfe7bcc7063eea321d8eff3193ecc9cdaecbeae662f2900c2244fc6?context=explore > > It's possible to install all staging artifacts with a single command > (preferably using the kamel CLI you find in Camel K release files): > > $ kamel install --operator-image=camelk/camel-k:2.3.2 --olm=false > > Please test this release candidate and cast your vote. > > [ ] +1 Release Apache Camel K 2.3.2 > [ ] -1 Veto the release (provide specific comments) > > The vote is open for at least 72 hours. > > I start the vote with my +1. > > Thanks and regards, > Pasquale Congiusti > > [1] https://github.com/apache/camel-k/milestone/51?closed=1 -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 4.6.0
+1 (non-binding) Em seg., 13 de mai. de 2024 às 08:56, Andrea Cosentino escreveu: > > Hello all, > > This is a vote for releasing camel-kamelets 4.6.0 > > This is a release supporting Camel 4.6.0 > > Kamelets release files: > https://dist.apache.org/repos/dist/dev/camel/camel-kamelets/4.6.0 > Kamelets staging repository: > https://repository.apache.org/content/repositories/orgapachecamel-1712 > Kamelets Tag: > https://github.com/apache/camel-kamelets/releases/tag/v4.6.0 > > Please cast your vote. > > [ ] +1 Release camel-kamelets 4.6.0 > [ ] -1 Veto the release (provide specific comments) > > The vote is open for at least 72 hours. > > Here's my +1. > > Thanks, > Andrea Cosentino -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Managing Quarkus dependencies when working with Native build
Em seg., 15 de abr. de 2024 às 15:14, Vladislav Krejcirik escreveu: > > Thanks for quick response! I do need reflection for my class. Please see my > dummy Integration below. When I removed annotation, it was not able to find > my ‘getRandomNumber’ method. When I added annotation, it worked just fine, > but my VS Code was complaining about missing Quarkus dependency. You can add the maven artifact: io.quarkus:quarkus-core to the dependency list, so the vscode can learn about the dependency. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Managing Quarkus dependencies when working with Native build
Em seg., 15 de abr. de 2024 às 14:21, Vladislav Krejcirik escreveu: > > I’m building Kamel K integration where I’m using Native build due to sparing > some Kubernetes resources. I’m using VS Code and RH extension pack for Camel. > It seems like I need to tag all my classes with @RegisterForReflection. When > I do that, I’m having unresolved dependency - > io.quarkus.runtime.annotations.RegisterForReflection. Since the project is > not managed by either Maven or Gradle, what is the good practice for > including Quarkus .jar files for design time? Your code only needs RegisterForReflection annotation if your custom classes do reflection, see https://camel.apache.org/camel-quarkus/3.8.x/user-guide/native-mode.html#reflection Otherwise there is no need for the annotation. For in depth doc about the extension development in camel, see https://camel.apache.org/camel-quarkus/3.8.x/contributor-guide/create-new-extension.html -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Unable to get Openapi/swagger in Camel Quarkus
Em ter., 9 de abr. de 2024 às 13:50, Mikael Andersson Wigander escreveu: > > I have a Quarkus Camel application which exposes a REST interface. > I have followed the process of adding the dependencies and created the > definition but I can not get anything in the Quarkus Swagger UI. you can get this example https://github.com/apache/camel-quarkus-examples/tree/main/rest-json and add the dependencies org.apache.camel.quarkus:camel-quarkus-openapi-java io.quarkus:quarkus-smallrye-openapi and curl localhost:8080/q/openapi Then you can adjust your project to the example -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 4.5.0
+1 (non-binding) Em ter., 2 de abr. de 2024 às 06:48, Andrea Cosentino escreveu: > > Hello all, > > This is a vote for releasing camel-kamelets 4.5.0 > > This is a release supporting Camel 4.5.0 and it's a development release. > > Kamelets release files: > https://dist.apache.org/repos/dist/dev/camel/camel-kamelets/4.5.0 > Kamelets staging repository: > https://repository.apache.org/content/repositories/orgapachecamel-1692 > Kamelets Tag: > https://github.com/apache/camel-kamelets/releases/tag/v4.5.0 > > Please cast your vote. > > [ ] +1 Release camel-kamelets 4.5.0 > [ ] -1 Veto the release (provide specific comments) > > The vote is open for at least 72 hours. > > Here's my +1. > > Thanks, > Andrea Cosentino -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 4.4.1
+1 (non-binding) Em sex., 22 de mar. de 2024 às 06:05, Andrea Cosentino escreveu: > > Hello all, > > This is a vote for releasing camel-kamelets 4.4.1 > > This is the second release of camel-kamelets supporting LTS Camel 4.4.x and > it contains alignment to 4.4.1 and some fixes. > > Kamelets release files: > https://dist.apache.org/repos/dist/dev/camel/camel-kamelets/4.4.1 > Kamelets staging repository: > https://repository.apache.org/content/repositories/orgapachecamel-1687 > Kamelets Tag: > https://github.com/apache/camel-kamelets/releases/tag/v4.4.1 > > Please cast your vote. > > [ ] +1 Release camel-kamelets 4.4.1 > [ ] -1 Veto the release (provide specific comments) > > The vote is open for at least 72 hours. > > Here's my +1. > > Thanks, > Andrea Cosentino -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 4.0.3
+1 non binding -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Seeking documentation how to write consumer endpoint
Em sex., 12 de jan. de 2024 às 13:42, Jan Bares, WOOD & Co. escreveu: > > we already use everything you mension bellow on files that *do not change*. > My current requirement is to read file that *changes* over the time, I can > imagine that we can handle appends with Camel but we need also to handle and > *detect* (e.g. set special header) , when the file is *truncated*. There is a component to watch file changes. https://camel.apache.org/components/4.0.x/file-watch-component.html If you want to optimize the read operation to read specific file content, you have to look at ways to control content read for special marks and content. camel-file component has some configuration to allow you to plug your implementation, look for processStrategy, https://camel.apache.org/components/4.0.x/file-component.html -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Seeking documentation how to write consumer endpoint
Em sex., 12 de jan. de 2024 às 12:28, Jan Bares, WOOD & Co. escreveu: > > I need to read a XML file with list of tags (or just chunks of text delimited > by some string) given the following constraints > * new chunks are added at the end, each new chunk should create new Exchange > * the file can be truncated to zero length and started over at any time, > special Exchange must be created > * the header of the file contains "creation timestamp" that is used to detect > the file truncation >From what you described you don't have to create a new component, but to create a route that uses a consumer to receive the xml payload and then process it. The consumer can be a file, ftp, queue, etc. The processor will read the xml payload and process it. Then the resulting work may be sent for post processing purposes to other system. I suggest you read about camel EIPs, there are several ways to process the xml payload. Look for streaming, split, tokenizer, filter. https://camel.apache.org/components/4.0.x/eips/enterprise-integration-patterns.html https://github.com/apache/camel-examples/tree/main -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Camel K: Is it possible to enhance the CamelCatalog resource with custom Camel components, dataformats?
Em qui., 9 de nov. de 2023 às 09:42, Franz Paul Forsthofer escreveu: > > Can I enhance the CamelCatalog with custom Camel components, dataformats? That's some hacking, there is nothing that prevents it, from the top of my mind. There is no testing about changing it outside the controller, and may result in unforeseen behavior. The CamelCatalog custom resource is managed by the controller, using the status subresource, you can give it a try, but this is an unsupported situation, which we don't recommend. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Google Pubsub with Camel 3.11.7
Em ter., 24 de out. de 2023 às 18:41, Emily Shih escreveu: > > There are no logs that > indicate any failures, so we are not sure what's going on. Have you enabled debug log for camel and google pubsub categories ? org.apache.camel.component.google.pubsub com.google.cloud.pubsub They may show additional diagnostics. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 4.0.0
+1 non binding -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: How to upload data to S3 as Multipart file while getting data in loopDoWhile EIP from Paginated API
> I want to upload all this data received from all pages of paginated API to > be uploaded as single file in s3 (Multipart file). Camel S3 supports multipart upload to S3 https://camel.apache.org/components/3.21.x/aws2-s3-component.html#_s3_producer_operation_examples -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Kamelets that use other kamelets?
On Sat, Aug 19, 2023 at 3:38 AM Mikael Koskinen wrote: > > Should it be possible to use kamelets from other kamelets? I'm seeing some > errors, making it feel this isn't supported. There is the action kamelet to be used as an intermediate step from source to sink. It's not what you request, but it's closer. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: wiretap to kamelet question
On Sun, Apr 23, 2023 at 3:46 PM Ivan Tam wrote:
>
> 2023-04-23 11:33:58.277 INFO 1493992 --- [ main]
> org.apache.camel.main.MainSupport: Apache Camel (JBang) 3.20.1 is
> starting
> 2023-04-23 11:33:58.427 INFO 1493992 --- [ main]
> org.apache.camel.main.MainSupport: Using Java 17.0.6 with PID
> 1493992. Started by devname in /home/devname/examples/test-kamelet
> Caused by: org.apache.camel.FailedToStartRouteException: Failed to start
> route test-sink-1 because of Multiple consumers for the same endpoint is not
> allowed: kamelet://source?routeId=test-sink-1
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:376)
> ~[camel-base-engine-3.20.1.jar:3.20.1]
I was able to run your code using Java 11, can you try with it ?
I think the way wireTap was designed, you should have a "direct"
endpoint to wiretap into it, similar to:
from("timer:abc?period=3000")
.setBody().constant("1")
.setHeader("main_cid").constant("1234")
.wireTap("direct:tap")
.setHeader("main_cid").constant("2345")
.wireTap("direct:tap")
.setBody().constant("2")
.log("${body}");
from("direct:tap")
.delay(1000)
.to("kamelet:log-sink?message=${header.main_cid}");
Then you should be able to run with java 17.
--
Claudio Miranda
clau...@claudius.com.br
http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 3.20.3
+1 (non binding) -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: How can I add Routes use Spring DSL when use SpringBoot?
On Thu, Apr 6, 2023 at 12:30 PM mongoosej wrote: > > How can I add Routes use Spring DSL when I use SpringBoot? > In my project, I use SpringBoot not Spring, and I write route use XML not > Java DSL, then I get error when I startup my SpringBoot application: There are several examples using spring boot, please have a look there https://github.com/apache/camel-spring-boot-examples -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Consume Files with specific dynamic content only
On Wed, Feb 22, 2023 at 3:22 AM Reto Peter wrote: > > Is there any chance I can access the Exchange inside the filter > (GenericFileFilter)? > Or how can I achieve to process only files with specific dynamic content Your route has to access the message content, you can use the content filter. You can have a strategy to read only the first few lines to detect the content. https://camel.apache.org/components/3.20.x/eips/content-filter-eip.html -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: [VOTE] Release Apache Camel Kamelets 3.20.0
+1 (non binding) -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Integrating Apache Beam and Apache Camel
On Wed, Nov 16, 2022 at 1:57 PM John Casey wrote: > > from(something1?).to(some:existing:camel:component) > from(some:existing:camel:component?with=config).to(something2?) Look at the "To Dynamic" endpoint, you can set the endpoint string at runtime. https://camel.apache.org/components/3.18.x/eips/toD-eip.html -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Can we use custom socket connection in RabbitMQ camel component
On Wed, Nov 9, 2022 at 6:46 AM N Venkatesh wrote: > > We are trying to connect RabbitMQ server connection through existing camel > component using customized socket connection. Here we want to supply proxy > host and proxy port via customized socket connection object. > > Can you please tell us, RabbitMQ camel component will support customized > socket connection . I suggest to create a custom com.rabbitmq.client.ConnectionFactory and sets the SOCKS proxy, then register this connectionFactory and references it in the rabbitmq endpoint See how to create the rabbitmq connectionFactory https://groups.google.com/g/rabbitmq-users/c/b2zrs3FKiLo -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: User defined beans and processor in Kamelets
On Mon, Oct 17, 2022 at 1:21 AM Bikash Kaushik wrote: > > I want to call/use my custom beans that I created for data processing in > Camel-K (Kamelets). You can use the "bean" in your kamelet as - bean: "org.apache.camel.kamelets.utils.transform.HoistField" Declare the dependency as: dependencies: - github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT The example kamelet https://github.com/apache/camel-kamelets/blob/main/kamelets/hoist-field-action.kamelet.yaml#L61 The custom bean class https://github.com/apache/camel-kamelets/blob/main/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/transform/HoistField.java -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Custom component : route not completing on second call
On Tue, Sep 27, 2022 at 3:45 AM Stefan Kok wrote: > > I have listed snippets of the relevant code below. At present, the > first call to the code will return the correct result. However, on Would it be possible to share this code as a project to build and run ? This way, more people feel easier to assist you. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Is there a versioning concept for Kamelets ?
On Mon, Sep 26, 2022 at 1:27 PM Christoph Weiss wrote: > > From my understanding the link between an Integration and Kamelet CR is only > done based on the “Kamelet name”. Do you mean the KameletBinding ? If yes, then from the KameletBinding you can navigate to the integration by looking at "status.selector" k get KameletBinding/timed-greeter-binding -oyaml selector: camel.apache.org/integration=timed-greeter-binding >From the Integration object you have labels and ownerReferences fields labels: camel.apache.org/created.by.kind: KameletBinding camel.apache.org/created.by.name: timed-greeter-binding name: timed-greeter-binding ownerReferences: - apiVersion: camel.apache.org/v1alpha1 blockOwnerDeletion: true controller: true kind: KameletBinding name: timed-greeter-binding > There is no option to define within the Integration any additional version or > filtering tag for a Kamelet. You can add any label to the KameletBinding, that is propagated to the integration object. Please, elaborate, if I misunderstood your question. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: netty http component - SNI missing in SSL handshake
On Thu, Sep 15, 2022 at 7:00 AM Bheda, Nitesh wrote: > > Artifact : camel-netty-http version : 2.18.3 Can you try a more recent version, see https://camel.apache.org/download/ Try it on a dev machine, if it is fixed on it. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: Camel-K modelines: is it possible to access ConfgMaps and Secrets in another namespace ?
On Tue, Sep 13, 2022 at 1:49 PM Christoph Weiss wrote: > > Is it possible to acess ConfigMaps and Secrets in another namespace using > “config / resource modeline”? (see > https://camel.apache.org/camel-k/1.9.x/cli/modeline.html) Not possible at the moment, since that would require additional role/rolebinding and the client api doesn't set a custom namespace in the operator code. You can add an issue with an example use case for further discussion. -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
Re: kamel run - which component creates the Kubernetes CR ?
On Mon, Sep 12, 2022 at 11:21 AM Christoph Weiss wrote: > > Short question: I am wondering which “component” is creating the “Kubernetes > Integration CR” when running “kamel run” (based on a given Integration > written e.g. in groovy or any other DSL). Hi, the kamel run creates the Integration CR (client side) https://github.com/apache/camel-k/blob/main/pkg/cmd/run.go#L496 And the k8s client creates the CR in the cluster https://github.com/apache/camel-k/blob/main/pkg/cmd/run.go#L559 Is this what you want ? -- Claudio Miranda clau...@claudius.com.br http://www.claudius.com.br
