Java consumer. Kafka java. spark code 28.