sparkstreaming之kafka---KafkaClientApp

package com.yys.spark.kafka; /**  * Kafka Java API测试  */ public class KafkaClientApp {     public static void main(String[] args) {         new KafkaProducer(KafkaProperties.TOPIC).start();         new KafkaConsumer(KafkaProperties.TOPIC).start();     } }