@@ -0,0 +1,698 @@
+package com.jasongj.kafka.connect;%0A%0Aimport java.util.Collection;%0Aimport java.util.Map;%0A%0Aimport org.apache.kafka.clients.consumer.OffsetAndMetadata;%0Aimport org.apache.kafka.common.TopicPartition;%0Aimport org.apache.kafka.connect.sink.SinkRecord;%0Aimport org.apache.kafka.connect.sink.SinkTask;%0A%0Apublic class ConsoleSinkTask extends SinkTask %7B%0A%0A    @Override%0A    public String version() %7B%0A        return null;%0A    %7D%0A%0A    @Override%0A    public void flush(Map%3CTopicPartition, OffsetAndMetadata%3E arg0) %7B%0A%0A    %7D%0A%0A    @Override%0A    public void put(Collection%3CSinkRecord%3E arg0) %7B%0A%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%7D%0A

Add ConsoleSinkTask