Path	Lines of Code
amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/coordinator/KinesisClientLibConfiguration.java	571
amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java	201
amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/PeriodicShardSyncManager.java	355
amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java	753
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java	576
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java	237
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java	275
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java	545
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java	393
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/BlockOnParentShardTask.java	63
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java	273
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java	355
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownNotificationTask.java	35
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutConsumerRegistration.java	183
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/KinesisDataFetcher.java	266