You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
For our case specifically, we would like to pseduo-replicate our SQS messages into kafka for analysis to gain visibility with SQL where SQS leaves us fairly blind and forces us to rely on logging or tracing.
If this were to delete the record on the consumer, this would cause production issues for us.
A simple feature flag or environment variable would be great.
Happy to provide a PR
The text was updated successfully, but these errors were encountered:
Our use case is fairly unique, but I feel like this could also be helpful for other edge cases.
Currently, the https://github.com/Nordstrom/kafka-connect-sqs/blob/master/src/main/java/com/nordstrom/kafka/connect/sqs/SqsSourceConnectorTask.java#L115 class is set to always delete, which can make both testing and monitoring solutions difficult.
For our case specifically, we would like to pseduo-replicate our SQS messages into kafka for analysis to gain visibility with SQL where SQS leaves us fairly blind and forces us to rely on logging or tracing.
If this were to delete the record on the consumer, this would cause production issues for us.
A simple feature flag or environment variable would be great.
Happy to provide a PR
The text was updated successfully, but these errors were encountered: