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
addon packages rename to connector
Merge branch 'master' of https://github.com/stratosphere/stratosphere-streaming
merge
merge
explicit output flushing readded + need fix
Merge branch 'master' into intern
Merge branch 'master' into serialization-test