added basic kafka impl with test program