Rename package to uk.sky

README.md

@@ -17,7 +17,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()

src/main/scala/com/sky/kafka/topicloader/TopicLoader.scala → 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._

src/main/scala/com/sky/kafka/topicloader/config/config.scala → 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._

src/main/scala/com/sky/kafka/topicloader/config/topicLoaderConfig.scala → 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.

src/main/scala/com/sky/kafka/topicloader/loadTopicStrategy.scala → 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
 

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._

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._