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/10/05 15:06:25 UTC

[GitHub] [camel-kafka-connector] NeilMurray6p6 opened a new issue #1266: AWS SQS Source Message Delete

NeilMurray6p6 opened a new issue #1266:
URL: https://github.com/apache/camel-kafka-connector/issues/1266


   Setting up Kafka Connect with the following config results in SQS message being written to topic indefinitely because the SQS message is not deleted after read.
   
   ```
   {
     "name": "sqs-source-connector-aws",
     "config": {
       "connector.class": "org.apache.camel.kafkaconnector.aws2sqs.CamelAws2sqsSourceConnector",
       "tasks.max": "1",
       "key.converter": "org.apache.kafka.connect.storage.StringConverter",
       "value.converter": "org.apache.kafka.connect.storage.StringConverter",
       "topics": "sqs-topic-aws",
       "camel.source.path.queueNameOrArn": "tt",
       "camel.source.maxPollDuration": 10000,
       "camel.component.aws2-sqs.accessKey": "XXX",
       "camel.component.aws2-sqs.secretKey": "YYY",
       "camel.component.aws2-sqs.region": "eu-west-2"
     }
   }
   ```
   
   Logs confirm that sqs.deleteAfterRead is true
   
   ```kafka-connect      | 	camel.component.aws2-sqs.deleteAfterRead = true```
   
   Is there some missing config which needs to be set to enable camel SQS message deletion?
   


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [camel-kafka-connector] oscerd commented on issue #1266: AWS SQS Source Message Delete

Posted by GitBox <gi...@apache.org>.
oscerd commented on issue #1266:
URL: https://github.com/apache/camel-kafka-connector/issues/1266#issuecomment-936068324


   I cannot reproduce this with 0.10.1 and 0.11.0


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [camel-kafka-connector] NeilMurray6p6 closed issue #1266: AWS SQS Source Message Delete

Posted by GitBox <gi...@apache.org>.
NeilMurray6p6 closed issue #1266:
URL: https://github.com/apache/camel-kafka-connector/issues/1266


   


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [camel-kafka-connector] NeilMurray6p6 commented on issue #1266: AWS SQS Source Message Delete

Posted by GitBox <gi...@apache.org>.
NeilMurray6p6 commented on issue #1266:
URL: https://github.com/apache/camel-kafka-connector/issues/1266#issuecomment-936474229


   Thanks for checking. I got it working now by upgrading Kafka Connect to version 6.x.x
   
   Seems like my setup using Kafka Connect 5.x.x wasn't calling `commitRecord()`


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org