kafka in kafka out generic code invoker based on Spark Streams