You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2021/03/22 14:03:54 UTC
[GitHub] [camel-kamelets] oscerd opened a new pull request #78: SQS Fifo Kamelet Sink
oscerd opened a new pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78
Fixes #77
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kamelets] oscerd commented on pull request #78: SQS Fifo Kamelet Sink
Posted by GitBox <gi...@apache.org>.
oscerd commented on pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78#issuecomment-804764324
Looks good!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kamelets] oscerd merged pull request #78: SQS Fifo Kamelet Sink
Posted by GitBox <gi...@apache.org>.
oscerd merged pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kamelets] nicolaferraro commented on a change in pull request #78: SQS Fifo Kamelet Sink
Posted by GitBox <gi...@apache.org>.
nicolaferraro commented on a change in pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78#discussion_r598781243
##########
File path: aws-sqs-fifo-sink.kamelet.yaml
##########
@@ -0,0 +1,64 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: aws-sqs-fifo-sink
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcKICAgeG1sbnM6ZGM9Imh0dHA6Ly9wdXJsLm9yZy9kYy9lbGVtZW50cy8xLjEvIgogICB4bWxuczpjYz0iaHR0cDovL2NyZWF0aXZlY29tbW9ucy5vcmcvbnMjIgogICB4bWxuczpyZGY9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkvMDIvMjItcmRmLXN5bnRheC1ucyMiCiAgIHhtbG5zOnN2Zz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciCiAgIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM6c29kaXBvZGk9Imh0dHA6Ly9zb2RpcG9kaS5zb3VyY2Vmb3JnZS5uZXQvRFREL3NvZGlwb2RpLTAuZHRkIgogICB4bWxuczppbmtzY2FwZT0iaHR0cDovL3d3dy5pbmtzY2FwZS5vcmcvbmFtZXNwYWNlcy9pbmtzY2FwZSIKICAgZW5hYmxlLWJhY2tncm91bmQ9Im5ldyAwIDAgMTAwIDEwMCIKICAgaGVpZ2h0PSI3Mi4xOTk5OTciCiAgIHZlcnNpb249IjEuMSIKICAgdmlld0JveD0iMCAwIDU5Ljg0OTk5OCA3Mi4xOTk5OTciCiAgIHdpZHRoPSI1OS44NDk5OTgiCiAgIHhtbDpzcGFjZT0icHJlc2VydmUiCiAgIGlkPSJzdmcxNDUiCiAgIHNvZGlwb2RpOmRvY25hbWU9ImRvd25sb2FkLnN2ZyIKICAgaW5rc2NhcGU6dmVyc2lvbj0iMS4wLjIgKGU4NmM4NzA4NzksIDIwMjEtMDEtMTUpIj48bWV0YWRhdGEKICA
gICBpZD0ibWV0YWRhdGExNTEiPjxyZGY6UkRGPjxjYzpXb3JrCiAgICAgICAgIHJkZjphYm91dD0iIj48ZGM6Zm9ybWF0PmltYWdlL3N2Zyt4bWw8L2RjOmZvcm1hdD48ZGM6dHlwZQogICAgICAgICAgIHJkZjpyZXNvdXJjZT0iaHR0cDovL3B1cmwub3JnL2RjL2RjbWl0eXBlL1N0aWxsSW1hZ2UiIC8+PGRjOnRpdGxlPjwvZGM6dGl0bGU+PC9jYzpXb3JrPjwvcmRmOlJERj48L21ldGFkYXRhPjxkZWZzCiAgICAgaWQ9ImRlZnMxNDkiIC8+PHNvZGlwb2RpOm5hbWVkdmlldwogICAgIHBhZ2Vjb2xvcj0iI2ZmZmZmZiIKICAgICBib3JkZXJjb2xvcj0iIzY2NjY2NiIKICAgICBib3JkZXJvcGFjaXR5PSIxIgogICAgIG9iamVjdHRvbGVyYW5jZT0iMTAiCiAgICAgZ3JpZHRvbGVyYW5jZT0iMTAiCiAgICAgZ3VpZGV0b2xlcmFuY2U9IjEwIgogICAgIGlua3NjYXBlOnBhZ2VvcGFjaXR5PSIwIgogICAgIGlua3NjYXBlOnBhZ2VzaGFkb3c9IjIiCiAgICAgaW5rc2NhcGU6d2luZG93LXdpZHRoPSIxOTIwIgogICAgIGlua3NjYXBlOndpbmRvdy1oZWlnaHQ9IjEwMTYiCiAgICAgaWQ9Im5hbWVkdmlldzE0NyIKICAgICBzaG93Z3JpZD0iZmFsc2UiCiAgICAgZml0LW1hcmdpbi10b3A9IjAuMSIKICAgICBmaXQtbWFyZ2luLWxlZnQ9IjAuMSIKICAgICBmaXQtbWFyZ2luLXJpZ2h0PSIwLjEiCiAgICAgZml0LW1hcmdpbi1ib3R0b209IjAuMSIKICAgICBpbmtzY2FwZTp6b29tPSI4LjE5IgogICAgIGlua3NjYXBlOmN4PSIy
OS45MjUiCiAgICAgaW5rc2NhcGU6Y3k9IjM2LjEiCiAgICAgaW5rc2NhcGU6d2luZG93LXg9IjAiCiAgICAgaW5rc2NhcGU6d2luZG93LXk9IjI3IgogICAgIGlua3NjYXBlOndpbmRvdy1tYXhpbWl6ZWQ9IjEiCiAgICAgaW5rc2NhcGU6Y3VycmVudC1sYXllcj0ic3ZnMTQ1IiAvPjxnCiAgICAgaWQ9IkFtYXpvbl9DbG91ZFNlYXJjaCIKICAgICB0cmFuc2Zvcm09InRyYW5zbGF0ZSgtMjAuMDc1LC0xMy45KSI+PGcKICAgICAgIGlkPSJnMTQyIj48cG9seWdvbgogICAgICAgICBmaWxsPSIjZDlhNzQxIgogICAgICAgICBwb2ludHM9IjIzLjk4NywzNi4yMDEgNTQuNDYyLDQwLjQ5NCA1NC40Niw1OS41MDYgMjMuOTg1LDYzLjc5MyAiCiAgICAgICAgIGlkPSJwb2x5Z29uMTIwIiAvPjxwb2x5Z29uCiAgICAgICAgIGZpbGw9IiM4NzY5MjkiCiAgICAgICAgIHBvaW50cz0iNTAuMDAzLDE0IDIwLjE3OSwyOC45MDggMjAuMTc5LDM3LjM0NCA1MC4wMDMsMjguMzk5ICIKICAgICAgICAgaWQ9InBvbHlnb24xMjIiIC8+PHBvbHlnb24KICAgICAgICAgZmlsbD0iIzg3NjkyOSIKICAgICAgICAgcG9pbnRzPSI0OS45OTcsODYgMjAuMTksNzEuMDk0IDIwLjE5LDYyLjY1NCA0OS45OTksNzEuNiAiCiAgICAgICAgIGlkPSJwb2x5Z29uMTI0IiAvPjxwb2x5Z29uCiAgICAgICAgIGZpbGw9IiNkOWE3NDEiCiAgICAgICAgIHBvaW50cz0iNTAuMDAzLDE0IDc5LjgyNSwyOC45MTQgNzkuODIzLDM3LjM1IDUwLjAwMywyOC4zOTkgI
gogICAgICAgICBpZD0icG9seWdvbjEyNiIgLz48cG9seWdvbgogICAgICAgICBmaWxsPSIjZDlhNzQxIgogICAgICAgICBwb2ludHM9IjQ5Ljk5Nyw4NiA3OS44MDYsNzEuMDk5IDc5LjgwNiw2Mi42NiA0OS45OTksNzEuNiAiCiAgICAgICAgIGlkPSJwb2x5Z29uMTI4IiAvPjxwb2x5Z29uCiAgICAgICAgIGZpbGw9IiM4NzY5MjkiCiAgICAgICAgIHBvaW50cz0iMjAuMTc5LDI4LjkwOCAyMy45ODksMjcuMDA0IDIzLjk4NSw3Mi45OSAyMC4xNzUsNzEuMDg2ICIKICAgICAgICAgaWQ9InBvbHlnb24xMzAiIC8+PHBvbHlnb24KICAgICAgICAgZmlsbD0iIzg3NjkyOSIKICAgICAgICAgcG9pbnRzPSI1MC4wMDEsNDAuODMyIDM5LjAxOSw0Mi4yMjkgMzkuMDE3LDU3Ljc2MiA0OS45OTksNTkuMTYgIgogICAgICAgICBpZD0icG9seWdvbjEzMiIgLz48cG9seWdvbgogICAgICAgICBmaWxsPSIjODc2OTI5IgogICAgICAgICBwb2ludHM9IjM1LjA4Myw0Mi43MjkgMjcuOTU0LDQzLjYzNyAyNy45NTQsNTYuMzU0IDM1LjA4MSw1Ny4yNiAiCiAgICAgICAgIGlkPSJwb2x5Z29uMTM0IiAvPjxwb2x5Z29uCiAgICAgICAgIGZpbGw9IiM2MjRhMWUiCiAgICAgICAgIHBvaW50cz0iNzkuODIzLDM3LjM1IDU0LjQ4MSw0MC40OTYgMjMuOTg3LDM2LjIwMSA1MC4wMDMsMjguMzk5ICIKICAgICAgICAgaWQ9InBvbHlnb24xMzYiIC8+PHBvbHlnb24KICAgICAgICAgZmlsbD0iI2ZhZDc5MSIKICAgICAgICAgcG9pbnRzPSI3OS44MD
YsNjIuNjYgNTQuNDYsNTkuNTA2IDIzLjk4NSw2My43OTMgNDkuOTk5LDcxLjYgIgogICAgICAgICBpZD0icG9seWdvbjEzOCIgLz48cG9seWdvbgogICAgICAgICBmaWxsPSIjZDlhNzQxIgogICAgICAgICBwb2ludHM9IjUwLjAwMSw0MC44MzIgNzkuODA4LDQ0LjYyOSA3OS44MDgsNTUuMzMgNDkuOTk5LDU5LjA5MiAiCiAgICAgICAgIGlkPSJwb2x5Z29uMTQwIiAvPjwvZz48L2c+PC9zdmc+Cg=="
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: sink
+spec:
+ definition:
+ title: AWS SQS FIFO Sink
+ description: Send message to an AWS SQS FIFO Queue
+ required:
+ - queueNameOrArn
+ - accessKey
+ - secretKey
+ - region
+ - messageGroupIdStrategy
+ - messageDeduplicationIdStrategy
+ properties:
+ queueNameOrArn:
+ title: Queue Name
+ description: The SQS Queue name or ARN
+ type: string
+ accessKey:
+ title: Access Key
+ description: The access key obtained from AWS
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ secretKey:
+ title: Secret Key
+ description: The secret key obtained from AWS
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ region:
+ title: AWS Region
+ description: The AWS region to connect to
+ type: string
+ example: eu-west-1
+ messageGroupIdStrategy:
+ title: Message Group ID Strategy
+ description: Strategy for setting the messageGroupId on the message. Can be one of the following options useConstant, useExchangeId, usePropertyValue.
+ type: string
+ default: useExchangeId
+ messageDeduplicationIdStrategy:
+ title: Message Deduplication ID Strategy
+ description: Strategy for setting the messageDeduplicationId on the message. Can be one of the following options useExchangeId, useContentBasedDeduplication
+ type: string
+ default: useExchangeId
Review comment:
I was talking about these two
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kamelets] oscerd commented on pull request #78: SQS Fifo Kamelet Sink
Posted by GitBox <gi...@apache.org>.
oscerd commented on pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78#issuecomment-804267751
with camel-k cli 1.3.1 it is failing:
```
[1] 2021-03-22 17:40:22,163 ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main) Failed to start application: java.lang.IllegalArgumentException: Cannot compute endpoint URI: unable to find an EndpointUriFactory for scheme aws2-sqs
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.getEndpointUriFactory(StepParserSupport.java:121)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.createEndpointUri(StepParserSupport.java:84)
[1] at org.apache.camel.k.loader.yaml.parser.ToStepParser.toProcessor(ToStepParser.java:34)
[1] at org.apache.camel.k.loader.yaml.spi.ProcessorStepParser.invoke(ProcessorStepParser.java:30)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.convertSteps(StepParserSupport.java:60)
[1] at org.apache.camel.k.loader.yaml.parser.ChoiceStepParser.toProcessor(ChoiceStepParser.java:45)
[1] at org.apache.camel.k.loader.yaml.spi.ProcessorStepParser.invoke(ProcessorStepParser.java:30)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.convertSteps(StepParserSupport.java:60)
[1] at org.apache.camel.k.loader.yaml.parser.FromStepParser.process(FromStepParser.java:47)
[1] at org.apache.camel.k.loader.yaml.spi.StartStepParser.invoke(StartStepParser.java:28)
[1] at org.apache.camel.k.loader.yaml.YamlSourceLoader$1.accept(YamlSourceLoader.java:80)
[1] at org.apache.camel.k.loader.yaml.YamlSourceLoader$1.accept(YamlSourceLoader.java:76)
[1] at org.apache.camel.k.support.RouteBuilders$3.configure(RouteBuilders.java:57)
[1] at org.apache.camel.builder.RouteBuilder.checkInitialized(RouteBuilder.java:483)
[1] at org.apache.camel.builder.RouteBuilder.configureRoutes(RouteBuilder.java:430)
[1] at org.apache.camel.builder.RouteBuilder.addRoutesToCamelContext(RouteBuilder.java:405)
[1] at org.apache.camel.impl.engine.AbstractCamelContext.addRoutes(AbstractCamelContext.java:1110)
[1] at org.apache.camel.main.RoutesConfigurer.configureRoutes(RoutesConfigurer.java:94)
[1] at org.apache.camel.main.BaseMainSupport.configureRoutes(BaseMainSupport.java:454)
[1] at org.apache.camel.main.BaseMainSupport.postProcessCamelContext(BaseMainSupport.java:474)
[1] at org.apache.camel.quarkus.main.CamelMain.initCamelContext(CamelMain.java:97)
[1] at org.apache.camel.quarkus.main.CamelMain.doInit(CamelMain.java:67)
[1] at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
[1] at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
[1] at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
[1] at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
[1] at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
[1] at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
[1] at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:534)
[1] at io.quarkus.runtime.Application.start(Application.java:90)
[1] at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:97)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:62)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:104)
[1] at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
[1]
[1] 2021-03-22 17:40:22,169 ERROR [io.qua.run.Application] (main) Failed to start application (with profile prod): java.lang.IllegalArgumentException: Cannot compute endpoint URI: unable to find an EndpointUriFactory for scheme aws2-sqs
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.getEndpointUriFactory(StepParserSupport.java:121)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.createEndpointUri(StepParserSupport.java:84)
[1] at org.apache.camel.k.loader.yaml.parser.ToStepParser.toProcessor(ToStepParser.java:34)
[1] at org.apache.camel.k.loader.yaml.spi.ProcessorStepParser.invoke(ProcessorStepParser.java:30)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.convertSteps(StepParserSupport.java:60)
[1] at org.apache.camel.k.loader.yaml.parser.ChoiceStepParser.toProcessor(ChoiceStepParser.java:45)
[1] at org.apache.camel.k.loader.yaml.spi.ProcessorStepParser.invoke(ProcessorStepParser.java:30)
[1] at org.apache.camel.k.loader.yaml.support.StepParserSupport.convertSteps(StepParserSupport.java:60)
[1] at org.apache.camel.k.loader.yaml.parser.FromStepParser.process(FromStepParser.java:47)
[1] at org.apache.camel.k.loader.yaml.spi.StartStepParser.invoke(StartStepParser.java:28)
[1] at org.apache.camel.k.loader.yaml.YamlSourceLoader$1.accept(YamlSourceLoader.java:80)
[1] at org.apache.camel.k.loader.yaml.YamlSourceLoader$1.accept(YamlSourceLoader.java:76)
[1] at org.apache.camel.k.support.RouteBuilders$3.configure(RouteBuilders.java:57)
[1] at org.apache.camel.builder.RouteBuilder.checkInitialized(RouteBuilder.java:483)
[1] at org.apache.camel.builder.RouteBuilder.configureRoutes(RouteBuilder.java:430)
[1] at org.apache.camel.builder.RouteBuilder.addRoutesToCamelContext(RouteBuilder.java:405)
[1] at org.apache.camel.impl.engine.AbstractCamelContext.addRoutes(AbstractCamelContext.java:1110)
[1] at org.apache.camel.main.RoutesConfigurer.configureRoutes(RoutesConfigurer.java:94)
[1] at org.apache.camel.main.BaseMainSupport.configureRoutes(BaseMainSupport.java:454)
[1] at org.apache.camel.main.BaseMainSupport.postProcessCamelContext(BaseMainSupport.java:474)
[1] at org.apache.camel.quarkus.main.CamelMain.initCamelContext(CamelMain.java:97)
[1] at org.apache.camel.quarkus.main.CamelMain.doInit(CamelMain.java:67)
[1] at org.apache.camel.support.service.BaseService.init(BaseService.java:83)
[1] at org.apache.camel.quarkus.main.CamelMain.startEngine(CamelMain.java:118)
[1] at org.apache.camel.quarkus.main.CamelMainRuntime.start(CamelMainRuntime.java:49)
[1] at org.apache.camel.quarkus.core.CamelBootstrapRecorder.start(CamelBootstrapRecorder.java:45)
[1] at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy_0(CamelBootstrapProcessor$boot-173480958.zig:101)
[1] at io.quarkus.deployment.steps.CamelBootstrapProcessor$boot-173480958.deploy(CamelBootstrapProcessor$boot-173480958.zig:40)
[1] at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:534)
[1] at io.quarkus.runtime.Application.start(Application.java:90)
[1] at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:97)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:62)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:38)
[1] at io.quarkus.runtime.Quarkus.run(Quarkus.java:104)
[1] at io.quarkus.runner.GeneratedMain.main(GeneratedMain.zig:29)
[1]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [camel-kamelets] nicolaferraro commented on pull request #78: SQS Fifo Kamelet Sink
Posted by GitBox <gi...@apache.org>.
nicolaferraro commented on pull request #78:
URL: https://github.com/apache/camel-kamelets/pull/78#issuecomment-804192079
I've pushed what I meant..
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org