Implements KafkaGrabber? for metadata and event data
Change-Id: I1ead4da8fca8eabf3a18fff999023b09a92ffd4c