Class KafkaAsyncCloser

java.lang.Object
org.apache.drill.exec.store.kafka.KafkaAsyncCloser
All Implemented Interfaces:
AutoCloseable

public class KafkaAsyncCloser extends Object implements AutoCloseable
Closes Kafka resources asynchronously which result does not depend on close method in order to improve query execution performance. For example, KafkaConsumer.
  • Constructor Details

    • KafkaAsyncCloser

      public KafkaAsyncCloser()
  • Method Details

    • close

      public void close(AutoCloseable autoCloseable)
      Closes given resource in separate thread using thread executor.
      Parameters:
      autoCloseable - resource to close
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable