amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java (9 lines): - line 253: // TODO: Check if this is the correct behavior - line 414: // TODO: Check if this is the correct behavior - line 446: // TODO: Check if this is the correct behavior - line 485: // TODO: check behavior - line 514: // TODO: Check if this is correct behavior - line 567: // TODO: Check behavior - line 610: // TODO: check behavior - line 645: // TODO: check the behavior - line 672: // TODO: Check if this is the correct behavior amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/PeriodicShardSyncManager.java (3 lines): - line 148: // TODO: Resume the shard sync from failed stream in the next attempt, to avoid syncing - line 149: // TODO: for already synced streams - line 300: // TODO : use minLease for new ListShards with startingShardId amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/KinesisDataFetcher.java (3 lines): - line 237: // TODO: Check if this metric is fine to be added - line 251: // TODO: Check behavior - line 334: // TODO: Check behavior amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java (2 lines): - line 77: // TODO: UserRecord Deprecation - line 157: // TODO: UserRecord Deprecation amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java (2 lines): - line 253: // TODO: Figure out what to do with lease manage <=> checkpoint relationship - line 259: // TODO: Move this configuration to lifecycle amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java (2 lines): - line 339: // TODO: notify shutdownrequested - line 488: // TODO: set shutdown reason amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java (2 lines): - line 129: //TODO: Need to add multistream support for this https://sim.amazon.com/issues/KinesisLTR-191 - line 815: //TODO: Verify before LTR launch that ending sequence number is still returned from the service. amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/coordinator/KinesisClientLibConfiguration.java (1 line): - line 628: // TODO: Should it come back? amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutConsumerRegistration.java (1 line): - line 94: // TODO: Figure out internal service exceptions amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownNotificationTask.java (1 line): - line 36: // TODO: remove if not used amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/BlockOnParentShardTask.java (1 line): - line 39: // TODO: Check for non null values amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java (1 line): - line 216: // TODO: check if this is the correct behavior for Interrupted Exception amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java (1 line): - line 123: // TODO: Make bufferSize configurable amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java (1 line): - line 132: * //TODO: Optimize verifying duplicate entries https://sim.amazon.com/issues/KinesisLTR-597. amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java (1 line): - line 69: // TODO: Remove these defaults and use the defaults in the config