@Override
    public void stop() {
        // Nothing to do since FileStreamSourceConnector has no background monitoring.
    }
Very simple source connector that works with stdin or a file.
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java