Add replicated partition test
Catch exceptions during shutdown
Simplify creation of delegates
Fix import
Add compression suport
Process only messages with offsets larger than initial fetch value. This is for supporting compression.
Add support for providing initial offsets
Decoding support
Massive refactoring
Tests
Further refactoring