Tags: robinpowered/kafka-connect-kinesis
Tags
Source connector (#1) * Initial commit. Record Processor is converting records. * Move to the poll based method because it is a better match for kafka connect. Task is working with unit tests. Good code coverage. * Added support to describe the stream for the shards. * Updated documentation. * Added shardId and streamName to the value outputted by the connector. * Added Jenkinsfile for build. * Added Range validators. * Removed vertica docker image because it is not used in this project. * Added support to select shards based on a regular expression. * Updated documentation.