Patch/adapt 401
- Add the ability to have multiple partitions per topic. This includes adding an array of topics in the .topics.json - this should be the preferred method going forward.
- Change the way the offset is set so that it is the highest of the messages received.
- Add in an offset out of range handler
- Add in the ability to throttle messages when going to Avro registry.
- Add in try/catch so that we should not have an uncaught exception on AVRO registry errors.