fixing kafkaStream Java API and adding test