in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [158:161]
public void stop() { logger.info("Stopping task"); geodeContext.close(false); }