test_class.declarator: CLUSTER = new EmbeddedSingleNodeKafkaCluster()
test_class.modifier: @ClassRule
      public static final
test_class.original_string: @ClassRule
      public static final EmbeddedSingleNodeKafkaCluster CLUSTER = new EmbeddedSingleNodeKafkaCluster();
test_class.type: EmbeddedSingleNodeKafkaCluster
test_class.var_name: CLUSTER
test_class.file: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
test_class.identifier: KafkaStreamsTest
test_case.body: @Test
      public void testCleanup() throws Exception {
          final Properties props = new Properties();
          props.setProperty(StreamsConfig.APPLICATION_ID_CONFIG, "testLocalCleanup");
          props.setProperty(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());
  
          final KStreamBuilder builder = new KStreamBuilder();
          final KafkaStreams streams = new KafkaStreams(builder, props);
  
          streams.cleanUp();
          streams.start();
          streams.close();
          streams.cleanUp();
      }
test_case.class_method_signature: KafkaStreamsTest.testCleanup()
test_case.full_signature: @Test public void testCleanup()
test_case.identifier: testCleanup
test_case.invocations: setProperty setProperty bootstrapServers cleanUp start close cleanUp
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCleanup()
focal_class.declarator: log = LoggerFactory.getLogger(KafkaStreams.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(KafkaStreams.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: STREAM_CLIENT_ID_SEQUENCE = new AtomicInteger(1)
focal_class.modifier: private static final
focal_class.original_string: private static final AtomicInteger STREAM_CLIENT_ID_SEQUENCE = new AtomicInteger(1);
focal_class.type: AtomicInteger
focal_class.var_name: STREAM_CLIENT_ID_SEQUENCE
focal_class.declarator: JMX_PREFIX = "kafka.streams"
focal_class.modifier: private static final
focal_class.original_string: private static final String JMX_PREFIX = "kafka.streams";
focal_class.type: String
focal_class.var_name: JMX_PREFIX
focal_class.declarator: CREATED = 0
focal_class.modifier: private static final
focal_class.original_string: private static final int CREATED = 0;
focal_class.type: int
focal_class.var_name: CREATED
focal_class.declarator: RUNNING = 1
focal_class.modifier: private static final
focal_class.original_string: private static final int RUNNING = 1;
focal_class.type: int
focal_class.var_name: RUNNING
focal_class.declarator: STOPPED = 2
focal_class.modifier: private static final
focal_class.original_string: private static final int STOPPED = 2;
focal_class.type: int
focal_class.var_name: STOPPED
focal_class.declarator: state = CREATED
focal_class.modifier: private
focal_class.original_string: private int state = CREATED;
focal_class.type: int
focal_class.var_name: state
focal_class.declarator: threads
focal_class.modifier: private final
focal_class.original_string: private final StreamThread[] threads;
focal_class.type: StreamThread[]
focal_class.var_name: threads
focal_class.declarator: metrics
focal_class.modifier: private final
focal_class.original_string: private final Metrics metrics;
focal_class.type: Metrics
focal_class.var_name: metrics
focal_class.declarator: processId
focal_class.modifier: private final
focal_class.original_string: private final UUID processId;
focal_class.type: UUID
focal_class.var_name: processId
focal_class.declarator: config
focal_class.modifier: private final
focal_class.original_string: private final StreamsConfig config;
focal_class.type: StreamsConfig
focal_class.var_name: config
focal_class.file: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
focal_class.identifier: KafkaStreams
focal_class.class_method_signature: KafkaStreams.KafkaStreams(final TopologyBuilder builder, final Properties props)
focal_class.full_signature: public  KafkaStreams(final TopologyBuilder builder, final Properties props)
focal_class.identifier: KafkaStreams
focal_class.modifiers: public
focal_class.parameters: (final TopologyBuilder builder, final Properties props)
focal_class.signature:  KafkaStreams(final TopologyBuilder builder, final Properties props)
focal_class.class_method_signature: KafkaStreams.KafkaStreams(final TopologyBuilder builder, final StreamsConfig config)
focal_class.full_signature: public  KafkaStreams(final TopologyBuilder builder, final StreamsConfig config)
focal_class.identifier: KafkaStreams
focal_class.modifiers: public
focal_class.parameters: (final TopologyBuilder builder, final StreamsConfig config)
focal_class.signature:  KafkaStreams(final TopologyBuilder builder, final StreamsConfig config)
focal_class.class_method_signature: KafkaStreams.KafkaStreams(final TopologyBuilder builder, final StreamsConfig config, final KafkaClientSupplier clientSupplier)
focal_class.full_signature: public  KafkaStreams(final TopologyBuilder builder, final StreamsConfig config, final KafkaClientSupplier clientSupplier)
focal_class.identifier: KafkaStreams
focal_class.modifiers: public
focal_class.parameters: (final TopologyBuilder builder, final StreamsConfig config, final KafkaClientSupplier clientSupplier)
focal_class.signature:  KafkaStreams(final TopologyBuilder builder, final StreamsConfig config, final KafkaClientSupplier clientSupplier)
focal_class.class_method_signature: KafkaStreams.start()
focal_class.full_signature: public synchronized void start()
focal_class.identifier: start
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void start()
focal_class.class_method_signature: KafkaStreams.close()
focal_class.full_signature: public synchronized void close()
focal_class.identifier: close
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: KafkaStreams.cleanUp()
focal_class.full_signature: public void cleanUp()
focal_class.identifier: cleanUp
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanUp()
focal_class.class_method_signature: KafkaStreams.setUncaughtExceptionHandler(final Thread.UncaughtExceptionHandler eh)
focal_class.full_signature: public void setUncaughtExceptionHandler(final Thread.UncaughtExceptionHandler eh)
focal_class.identifier: setUncaughtExceptionHandler
focal_class.modifiers: public
focal_class.parameters: (final Thread.UncaughtExceptionHandler eh)
focal_class.return: void
focal_class.signature: void setUncaughtExceptionHandler(final Thread.UncaughtExceptionHandler eh)
focal_method.body: public void cleanUp() {
          if (this.state == RUNNING) {
              throw new IllegalStateException("Cannot clean up while running.");
          }
  
          final String localApplicationDir = this.config.getString(StreamsConfig.STATE_DIR_CONFIG)
              + File.separator
              + this.config.getString(StreamsConfig.APPLICATION_ID_CONFIG);
  
          log.debug("Clean up local Kafka Streams data in {}", localApplicationDir);
          log.debug("Removing local Kafka Streams application data in {} for application {}",
              localApplicationDir,
              this.config.getString(StreamsConfig.APPLICATION_ID_CONFIG));
          Utils.delete(new File(localApplicationDir));
      }
focal_method.class_method_signature: KafkaStreams.cleanUp()
focal_method.full_signature: public void cleanUp()
focal_method.identifier: cleanUp
focal_method.invocations: getString getString debug debug getString delete
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void cleanUp()