From bfd8b193ffd3c52b09f871952d0c8acea20c3756 Mon Sep 17 00:00:00 2001 From: Ben Carter Date: Fri, 29 Apr 2022 19:40:26 +0100 Subject: [PATCH] Rename package to uk.sky --- README.md | 2 +- .../{com => uk}/sky/kafka/topicloader/TopicLoader.scala | 4 ++-- .../{com => uk}/sky/kafka/topicloader/config/config.scala | 2 +- .../sky/kafka/topicloader/config/topicLoaderConfig.scala | 4 ++-- .../sky/kafka/topicloader/loadTopicStrategy.scala | 2 +- src/test/scala/integration/DeprecatedMethodsIntSpec.scala | 2 +- src/test/scala/integration/TopicLoaderIntSpec.scala | 6 +++--- 7 files changed, 11 insertions(+), 11 deletions(-) rename src/main/scala/{com => uk}/sky/kafka/topicloader/TopicLoader.scala (99%) rename src/main/scala/{com => uk}/sky/kafka/topicloader/config/config.scala (95%) rename src/main/scala/{com => uk}/sky/kafka/topicloader/config/topicLoaderConfig.scala (95%) rename src/main/scala/{com => uk}/sky/kafka/topicloader/loadTopicStrategy.scala (92%) diff --git a/README.md b/README.md index dc74a75d..27a868bc 100644 --- a/README.md +++ b/README.md @@ -17,7 +17,7 @@ libraryDependencies += "uk.sky" %% "kafka-topic-loader" % "" ``` ```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 64a0d247..4ac98ddf 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._