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); }