Quantcast

AWS Kinesis URI sequenceNumber unknown parameter

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
6 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

AWS Kinesis URI sequenceNumber unknown parameter

elaufis
I am using the Camel 2.18.1 Kinesis component.

When I try to use the 'sequenceNumber' parameter in the Kinesis URI as below:

aws-kinesis://DataFeedStream?amazonKinesisClient=#kinesisClient&delay=30s&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&runLoggingLevel=DEBUG&iteratorType=AFTER_SEQUENCE_NUMBER&sequenceNumber=49571334517568117679905736569937663848287351789108330498

I get the following error:

org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: aws-kinesis://DataFeedStream?amazonKinesisClient=%23kinesisClient&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&delay=30s&iteratorType=AFTER_SEQUENCE_NUMBER&runLoggingLevel=DEBUG&sequenceNumber=49571334517568117679905736569937663848287351789108330498 due to: Failed to resolve endpoint: aws-kinesis://DataFeedStream?amazonKinesisClient=%23kinesisClient&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&delay=30s&iteratorType=AFTER_SEQUENCE_NUMBER&runLoggingLevel=DEBUG&sequenceNumber=49571334517568117679905736569937663848287351789108330498 due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{sequenceNumber=49571334517568117679905736569937663848287351789108330498}]

The parameter name looks correct according to the docs here:
https://github.com/apache/camel/blob/master/components/camel-aws/src/main/docs/aws-kinesis-component.adoc

Any suggestions on how to resolve this?


Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: AWS Kinesis URI sequenceNumber unknown parameter

Claus Ibsen-2
Look in the docs for your version eg 2.18.1

On Wed, Mar 15, 2017 at 9:32 AM, elaufis <[hidden email]> wrote:

> I am using the Camel 2.18.1 Kinesis component.
>
> When I try to use the 'sequenceNumber' parameter in the Kinesis URI as
> below:
>
> aws-kinesis://DataFeedStream?amazonKinesisClient=#kinesisClient&delay=30s&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&runLoggingLevel=DEBUG&iteratorType=AFTER_SEQUENCE_NUMBER&sequenceNumber=49571334517568117679905736569937663848287351789108330498
>
> I get the following error:
>
> org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint:
> aws-kinesis://DataFeedStream?amazonKinesisClient=%23kinesisClient&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&delay=30s&iteratorType=AFTER_SEQUENCE_NUMBER&runLoggingLevel=DEBUG&sequenceNumber=49571334517568117679905736569937663848287351789108330498
> due to: Failed to resolve endpoint:
> aws-kinesis://DataFeedStream?amazonKinesisClient=%23kinesisClient&backoffIdleThreshold=5&backoffMultiplier=6&bridgeErrorHandler=true&delay=30s&iteratorType=AFTER_SEQUENCE_NUMBER&runLoggingLevel=DEBUG&sequenceNumber=49571334517568117679905736569937663848287351789108330498
> due to: There are 1 parameters that couldn't be set on the endpoint. Check
> the uri if the parameters are spelt correctly and that they are properties
> of the endpoint. Unknown
> parameters=[{sequenceNumber=49571334517568117679905736569937663848287351789108330498}]
>
> The parameter name looks correct according to the docs here:
> https://github.com/apache/camel/blob/master/components/camel-aws/src/main/docs/aws-kinesis-component.adoc
> <https://github.com/apache/camel/blob/master/components/camel-aws/src/main/docs/aws-kinesis-component.adoc>
>
> Any suggestions on how to resolve this?
>
>
>
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/AWS-Kinesis-URI-sequenceNumber-unknown-parameter-tp5795499.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: AWS Kinesis URI sequenceNumber unknown parameter

elaufis
I have checked the docs for 2.18.x here:

https://github.com/apache/camel/blob/camel-2.18.x/components/camel-aws/src/main/docs/aws-kinesis-component.adoc

The parameter name hasn't changed, so I still have the issue.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: AWS Kinesis URI sequenceNumber unknown parameter

elaufis
This post has NOT been accepted by the mailing list yet.
In reply to this post by Claus Ibsen-2
I have checked the docs for 2.18.x here:

https://github.com/apache/camel/blob/camel-2.18.x/components/camel-aws/src/main/docs/aws-kinesis-component.adoc

The parameter name hasn't changed, so I still have the issue.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: AWS Kinesis URI sequenceNumber unknown parameter

Tomohisa Igarashi
In reply to this post by elaufis
Hmm weird, actually the sequenceNumber is already there in 2.18.1
https://github.com/apache/camel/blob/camel-2.18.1/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java#L51

As following test is specifying it, you may want to run it through the debugger and see what is different.
https://github.com/apache/camel/blob/camel-2.18.1/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java

Thanks,
Tomo

On 03/15/2017 06:16 PM, elaufis wrote:

> I have checked the docs for 2.18.x here:
>
> https://github.com/apache/camel/blob/camel-2.18.x/components/camel-aws/src/main/docs/aws-kinesis-component.adoc
>
> The parameter name hasn't changed, so I still have the issue.
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/AWS-Kinesis-URI-sequenceNumber-unknown-parameter-tp5795499p5795509.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: AWS Kinesis URI sequenceNumber unknown parameter

elaufis
This has been resolved.

The issue was that an older version of the amazon-kinesis-client was being used for the CamelContext:
      <dependency>
            <groupId>com.amazonaws</groupId>
            <artifactId>amazon-kinesis-client</artifactId>
            <version>1.6.5</version>
        </dependency>

This was incompatible with the Camel Kinesis component 2.18.1.

Solution:

Upgrade amazon-kinesis-client dependency to:

      <dependency>
            <groupId>com.amazonaws</groupId>
            <artifactId>amazon-kinesis-client</artifactId>
            <version>1.7.2</version>
        </dependency>

Thanks Claus, Tomo for the quick responses.
Loading...