@Override
    public Map<SystemStreamPartition, String> getOffsetsAfter(Map<SystemStreamPartition, String> offsets) {
      return offsets.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, null));
    }
Console logging System factory that just writes the messages to the console output.
This system factory is useful when the user wants to print the output of the stream processing to console.
samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java