KafkaSink, added shutdown to KafkaSource
RMQ Sink for other types
RMQ source for multiple types
rmq source refactored
kafka sink and source for multiple types
merge
merge
Merge branch 'master' into intern