本文整理了Java中org.apache.spark.streaming.kafka.KafkaTestUtils.teardown()方法的一些代码示例，展示了KafkaTestUtils.teardown()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KafkaTestUtils.teardown()方法的具体详情如下：
包路径：org.apache.spark.streaming.kafka.KafkaTestUtils
类名称：KafkaTestUtils
方法名：teardown

KafkaTestUtils.teardown介绍

暂无

代码示例

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8

@After
public void tearDown() {
 if (sc != null) {
  sc.stop();
  sc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.10

@After
public void tearDown() {
 if (sc != null) {
  sc.stop();
  sc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.11

@After
public void tearDown() {
 if (sc != null) {
  sc.stop();
  sc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8_2.11

@After
public void tearDown() {
 if (sc != null) {
  sc.stop();
  sc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8_2.11

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.10

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.10

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.11

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka_2.11

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka

@After
public void tearDown() {
 if (sc != null) {
  sc.stop();
  sc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8_2.11

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}

代码示例来源：origin: org.apache.spark/spark-streaming-kafka-0-8

@After
public void tearDown() {
 if (ssc != null) {
  ssc.stop();
  ssc = null;
 }
 if (kafkaTestUtils != null) {
  kafkaTestUtils.teardown();
  kafkaTestUtils = null;
 }
}