Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Rename package to uk.sky #114

Merged
merged 2 commits into from
May 19, 2022
Merged

Rename package to uk.sky #114

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
fc25c99
Rename package to uk.sky
bcarter97 Apr 29, 2022
9362c67
Merge branch 'master' into 95/update-package-name
bcarter97 May 19, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down
4 changes: 2 additions & 2 deletions ...m/sky/kafka/topicloader/TopicLoader.scala → ...k/sky/kafka/topicloader/TopicLoader.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -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}
Expand All @@ -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._
Expand Down
2 changes: 1 addition & 1 deletion ...sky/kafka/topicloader/config/config.scala → ...sky/kafka/topicloader/config/config.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.sky.kafka.topicloader
package uk.sky.kafka.topicloader

import cats.data.ValidatedNec
import cats.implicits._
Expand Down
4 changes: 2 additions & 2 deletions ...opicloader/config/topicLoaderConfig.scala → ...opicloader/config/topicLoaderConfig.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.sky.kafka.topicloader.config
package uk.sky.kafka.topicloader.config

import java.util.concurrent.TimeUnit

Expand All @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion ...kafka/topicloader/loadTopicStrategy.scala → ...kafka/topicloader/loadTopicStrategy.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.sky.kafka.topicloader
package uk.sky.kafka.topicloader

sealed trait LoadTopicStrategy

Expand Down
2 changes: 1 addition & 1 deletion src/test/scala/integration/DeprecatedMethodsIntSpec.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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._
Expand Down
6 changes: 3 additions & 3 deletions src/test/scala/integration/TopicLoaderIntSpec.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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._
Expand Down