[streaming] Added high level kafka connector