public void stop()

in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java [130:133]


  public void stop() {
    logger.info("Stopping Apache Geode source task");
    geodeContext.close(true);
  }