diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/splunk/EventServlet.java b/src/main/java/com/github/jcustenborder/kafka/connect/splunk/EventServlet.java
index 1b1fcd2..30e2603 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/splunk/EventServlet.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/splunk/EventServlet.java
@@ -17,8 +17,8 @@
 
 import com.fasterxml.jackson.core.JsonFactory;
 import com.fasterxml.jackson.databind.JsonNode;
+import com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque;
 import com.google.api.client.json.Json;
-import io.confluent.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque;
 import org.apache.kafka.connect.source.SourceRecord;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceTask.java b/src/main/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceTask.java
index 439e6d9..a195d97 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceTask.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceTask.java
@@ -16,7 +16,7 @@
 package com.github.jcustenborder.kafka.connect.splunk;
 
 import com.fasterxml.jackson.core.JsonFactory;
-import io.confluent.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque;
+import com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque;
 import org.apache.kafka.connect.errors.ConnectException;
 import org.apache.kafka.connect.source.SourceRecord;
 import org.apache.kafka.connect.source.SourceTask;
diff --git a/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSinkConnectorConfigTest.java b/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSinkConnectorConfigTest.java
index 6c01485..92a86a8 100644
--- a/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSinkConnectorConfigTest.java
+++ b/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSinkConnectorConfigTest.java
@@ -15,7 +15,7 @@
  */
 package com.github.jcustenborder.kafka.connect.splunk;
 
-import io.confluent.kafka.connect.utils.config.MarkdownFormatter;
+import com.github.jcustenborder.kafka.connect.utils.config.MarkdownFormatter;
 import org.junit.jupiter.api.Test;
 
 public class SplunkHttpSinkConnectorConfigTest {
diff --git a/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceConnectorConfigTest.java b/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceConnectorConfigTest.java
index fe5ad7e..2b3936c 100644
--- a/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceConnectorConfigTest.java
+++ b/src/test/java/com/github/jcustenborder/kafka/connect/splunk/SplunkHttpSourceConnectorConfigTest.java
@@ -15,8 +15,8 @@
  */
 package com.github.jcustenborder.kafka.connect.splunk;
 
+import com.github.jcustenborder.kafka.connect.utils.config.MarkdownFormatter;
 import com.google.common.collect.ImmutableMap;
-import io.confluent.kafka.connect.utils.config.MarkdownFormatter;
 import org.eclipse.jetty.util.ssl.SslContextFactory;
 import org.junit.jupiter.api.Test;