@@ -0,0 +1,756 @@
+package com.jasongj.kafka.connect;%0A%0Aimport java.util.List;%0Aimport java.util.Map;%0A%0Aimport org.apache.kafka.common.config.ConfigDef;%0Aimport org.apache.kafka.connect.connector.Task;%0Aimport org.apache.kafka.connect.source.SourceConnector;%0A%0Apublic class ConsoleSourceConnect extends SourceConnector %7B%0A%0A    @Override%0A    public ConfigDef config() %7B%0A        return null;%0A    %7D%0A%0A    @Override%0A    public void start(Map%3CString, String%3E arg0) %7B%0A%0A    %7D%0A%0A    @Override%0A    public void stop() %7B%0A%0A    %7D%0A%0A    @Override%0A    public Class%3C? extends Task%3E taskClass() %7B%0A        return null;%0A    %7D%0A%0A    @Override%0A    public List%3CMap%3CString, String%3E%3E taskConfigs(int arg0) %7B%0A        return null;%0A    %7D%0A%0A    @Override%0A    public String version() %7B%0A        return null;%0A    %7D%0A%0A%7D%0A

Create ConsoleSourceConnect