diff --git a/kafka/src/main/java/com/metamx/tranquility/kafka/writer/TranquilityEventWriter.java b/kafka/src/main/java/com/metamx/tranquility/kafka/writer/TranquilityEventWriter.java
index 7cbf98d..0cbd2ff 100644
--- a/kafka/src/main/java/com/metamx/tranquility/kafka/writer/TranquilityEventWriter.java
+++ b/kafka/src/main/java/com/metamx/tranquility/kafka/writer/TranquilityEventWriter.java
@@ -20,8 +20,8 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Throwables;
-import com.metamx.common.logger.Logger;
-import com.metamx.common.parsers.ParseException;
+import io.druid.java.util.common.logger.Logger;
+import io.druid.java.util.common.parsers.ParseException;
 import com.metamx.tranquility.config.DataSourceConfig;
 import com.metamx.tranquility.finagle.FinagleRegistry;
 import com.metamx.tranquility.kafka.KafkaBeamUtils;