package com.jasongj.kafka.connect;

import java.util.List;
import java.util.Map;

import org.apache.kafka.common.config.ConfigDef;
import org.apache.kafka.connect.connector.Task;
import org.apache.kafka.connect.sink.SinkConnector;

public class ConsoleSinkConnect extends SinkConnector {

    @Override
    public ConfigDef config() {
        return null;
    }

    @Override
    public void start(Map<String, String> arg0) {
        
    }

    @Override
    public void stop() {
        
    }

    @Override
    public Class<? extends Task> taskClass() {
        return null;
    }

    @Override
    public List<Map<String, String>> taskConfigs(int arg0) {
        return null;
    }

    @Override
    public String version() {
        return null;
    }


}

@@ -29,16 +29,70 @@
 nnect;%0A%0A
+import java.util.ArrayList;%0Aimport java.util.HashMap;%0A
 import j
@@ -178,16 +178,68 @@
 figDef;%0A
+import org.apache.kafka.common.utils.AppInfoParser;%0A
 import o
@@ -518,32 +518,25 @@
 String%3E 
-arg0) %7B%0A        
+config) %7B
 %0A    %7D%0A%0A
@@ -658,36 +658,53 @@
 %0A        return 
-null
+ConsoleSinkTask.class
 ;%0A    %7D%0A%0A    @Ov
@@ -767,15 +767,190 @@
 int 
-arg0) %7B
+maxTasks) %7B%0A        List%3CMap%3CString, String%3E%3E tasks = new ArrayList%3CMap%3CString, String%3E%3E();%0A        Map%3CString, String%3E task = new HashMap%3CString, String%3E();%0A        tasks.add(task);
 %0A   
@@ -953,36 +953,37 @@
 %0A        return 
-null
+tasks
 ;%0A    %7D%0A%0A    @Ov
@@ -1026,32 +1026,54 @@
 %0A        return 
-null
+AppInfoParser.getVersion()
 ;%0A    %7D%0A%0A%0A%7D%0A

Implement ConsoleSinkConnector