in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java [58:62]
private static Map<String, Long> createOffset() { Map<String, Long> offset = new HashMap<>(); offset.put("OFFSET", 0L); return offset; }