Python Kafka Streaming Java