adopted the kafka example based on actors... not fully integrated yet... just compiles