diff --git a/README.md b/README.md
index 19cfef40..f30b3e26 100644
--- a/README.md
+++ b/README.md
@@ -19,7 +19,7 @@ libraryDependencies += "uk.sky" %% "kafka-topic-loader" % "<version>"
 ```
 
 ```scala
-import com.sky.kafka.topicloader.{LoadAll, TopicLoader}
+import uk.sky.kafka.topicloader.{LoadAll, TopicLoader}
 import org.apache.kafka.common.serialization.Deserializer}
 
 implicit val as: ActorSystem = ActorSystem()
diff --git a/src/main/scala/com/sky/kafka/topicloader/TopicLoader.scala b/src/main/scala/uk/sky/kafka/topicloader/TopicLoader.scala
similarity index 99%
rename from src/main/scala/com/sky/kafka/topicloader/TopicLoader.scala
rename to src/main/scala/uk/sky/kafka/topicloader/TopicLoader.scala
index fa8f4e5a..8d34f381 100644
--- a/src/main/scala/com/sky/kafka/topicloader/TopicLoader.scala
+++ b/src/main/scala/uk/sky/kafka/topicloader/TopicLoader.scala
@@ -1,4 +1,4 @@
-package com.sky.kafka.topicloader
+package uk.sky.kafka.topicloader
 
 import java.lang.{Long => JLong}
 import java.util.{List => JList, Map => JMap, Optional}
@@ -14,11 +14,11 @@ import cats.syntax.bifunctor._
 import cats.syntax.option._
 import cats.syntax.show._
 import cats.{Bifunctor, Show}
-import com.sky.kafka.topicloader.config.{Config, TopicLoaderConfig}
 import com.typesafe.scalalogging.LazyLogging
 import org.apache.kafka.clients.consumer._
 import org.apache.kafka.common.TopicPartition
 import org.apache.kafka.common.serialization._
+import uk.sky.kafka.topicloader.config.{Config, TopicLoaderConfig}
 
 import scala.concurrent.Future
 import scala.jdk.CollectionConverters._
diff --git a/src/main/scala/com/sky/kafka/topicloader/config/config.scala b/src/main/scala/uk/sky/kafka/topicloader/config/config.scala
similarity index 95%
rename from src/main/scala/com/sky/kafka/topicloader/config/config.scala
rename to src/main/scala/uk/sky/kafka/topicloader/config/config.scala
index eab6891f..13f48d14 100644
--- a/src/main/scala/com/sky/kafka/topicloader/config/config.scala
+++ b/src/main/scala/uk/sky/kafka/topicloader/config/config.scala
@@ -1,4 +1,4 @@
-package com.sky.kafka.topicloader
+package uk.sky.kafka.topicloader
 
 import cats.data.ValidatedNec
 import cats.implicits._
diff --git a/src/main/scala/com/sky/kafka/topicloader/config/topicLoaderConfig.scala b/src/main/scala/uk/sky/kafka/topicloader/config/topicLoaderConfig.scala
similarity index 95%
rename from src/main/scala/com/sky/kafka/topicloader/config/topicLoaderConfig.scala
rename to src/main/scala/uk/sky/kafka/topicloader/config/topicLoaderConfig.scala
index 86d31b49..4293be47 100644
--- a/src/main/scala/com/sky/kafka/topicloader/config/topicLoaderConfig.scala
+++ b/src/main/scala/uk/sky/kafka/topicloader/config/topicLoaderConfig.scala
@@ -1,4 +1,4 @@
-package com.sky.kafka.topicloader.config
+package uk.sky.kafka.topicloader.config
 
 import java.util.concurrent.TimeUnit
 
@@ -24,7 +24,7 @@ object PosInt {
 final case class Config(topicLoader: TopicLoaderConfig)
 
 /** @param parallelism
-  *   Determines how many Kafka records are processed in parallel by [[com.sky.kafka.topicloader.TopicLoader]]. We
+  *   Determines how many Kafka records are processed in parallel by [[uk.sky.kafka.topicloader.TopicLoader]]. We
   *   recommend using a parallelism > 1 if you are processing the records by sending them to an akka.actor.Actor. This
   *   is so that messages are buffered in the akka.actor.Actor's mailbox, improving performance versus using a
   *   parallelism of 1.
diff --git a/src/main/scala/com/sky/kafka/topicloader/loadTopicStrategy.scala b/src/main/scala/uk/sky/kafka/topicloader/loadTopicStrategy.scala
similarity index 92%
rename from src/main/scala/com/sky/kafka/topicloader/loadTopicStrategy.scala
rename to src/main/scala/uk/sky/kafka/topicloader/loadTopicStrategy.scala
index 13b08335..e30e4ea6 100644
--- a/src/main/scala/com/sky/kafka/topicloader/loadTopicStrategy.scala
+++ b/src/main/scala/uk/sky/kafka/topicloader/loadTopicStrategy.scala
@@ -1,4 +1,4 @@
-package com.sky.kafka.topicloader
+package uk.sky.kafka.topicloader
 
 sealed trait LoadTopicStrategy
 
diff --git a/src/test/scala/integration/DeprecatedMethodsIntSpec.scala b/src/test/scala/integration/DeprecatedMethodsIntSpec.scala
index be6b4573..c0115cb6 100644
--- a/src/test/scala/integration/DeprecatedMethodsIntSpec.scala
+++ b/src/test/scala/integration/DeprecatedMethodsIntSpec.scala
@@ -7,10 +7,10 @@ import akka.stream.scaladsl.Sink
 import akka.util.Timeout
 import base.IntegrationSpecBase
 import cats.data.NonEmptyList
-import com.sky.kafka.topicloader._
 import io.github.embeddedkafka.Codecs.{stringDeserializer, stringSerializer}
 import org.apache.kafka.clients.consumer._
 import org.apache.kafka.common.TopicPartition
+import uk.sky.kafka.topicloader._
 
 import scala.concurrent.Future
 import scala.jdk.CollectionConverters._
diff --git a/src/test/scala/integration/TopicLoaderIntSpec.scala b/src/test/scala/integration/TopicLoaderIntSpec.scala
index acbb5885..c809b00f 100644
--- a/src/test/scala/integration/TopicLoaderIntSpec.scala
+++ b/src/test/scala/integration/TopicLoaderIntSpec.scala
@@ -9,15 +9,15 @@ import akka.stream.testkit.scaladsl.TestSink
 import base.IntegrationSpecBase
 import cats.data.NonEmptyList
 import cats.syntax.option._
-import com.sky.kafka.topicloader.TopicLoader.consumerSettings
-import com.sky.kafka.topicloader._
-import com.sky.kafka.topicloader.config.Config
 import com.typesafe.config.{ConfigException, ConfigFactory}
 import io.github.embeddedkafka.Codecs.{stringDeserializer, stringSerializer}
 import org.apache.kafka.common.errors.{TimeoutException => KafkaTimeoutException}
 import org.apache.kafka.common.serialization.ByteArrayDeserializer
 import org.scalatest.prop.TableDrivenPropertyChecks._
 import org.scalatest.prop.Tables.Table
+import uk.sky.kafka.topicloader.TopicLoader.consumerSettings
+import uk.sky.kafka.topicloader._
+import uk.sky.kafka.topicloader.config.Config
 
 import scala.concurrent.Future
 import scala.concurrent.duration._