A framework for processing data on SNS+SQS and/or Kinesis streams.

 See the README.md file in qs-core/src/main/java/com/blacklocus/qs/drivers/ for an overview and examples.
It's true that the Kinesis *Client* Library manages your threads (one thread/consumer per shard), but the core Kinesis API let's you read from any shard.