[streaming] Kafka offset example & high level kafka connector