public void stop()

in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [158:161]


  public void stop() {
    logger.info("Stopping task");
    geodeContext.close(false);
  }