Don't include checkpoint in hashCode/equality for ShardInfo, since it changes. Checkpointing would cause the Worker to recreate the ShardConsumer. Add unit tests that verify the equality constraints. |
||
|---|---|---|
| .. | ||
| main/java/com/amazonaws/services/kinesis | ||
| test/java | ||