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
we want to run multiple instance of a kinesis consumer app in a k8s enviorment.
in order to make sure that we read and work on the data at least once we need to be able to extract the record from the stream, then perform some work, and only then commit the shard position to the ddb table.
i was wondering if this can be done in the kinsumer?
The text was updated successfully, but these errors were encountered:
we want to run multiple instance of a kinesis consumer app in a k8s enviorment.
in order to make sure that we read and work on the data at least once we need to be able to extract the record from the stream, then perform some work, and only then commit the shard position to the ddb table.
i was wondering if this can be done in the kinsumer?
The text was updated successfully, but these errors were encountered: