[FLINK-1196] [streaming] Added abstract fault tolerance layer
[streaming] Added Kafka fault tolerance layer