adding kafkaStream API tests