This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch ftp in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-samples.git
commit e9f77fed39a60e4ed57d1bca991f19c8d45fa464 Author: PJ Fanning <[email protected]> AuthorDate: Sat Dec 16 23:52:30 2023 +0100 migrate ftp sample --- docs/build.sbt | 17 +++++++---------- docs/project/plugins.sbt | 1 - ftp-to-file.conf | 10 +++++----- http-csv-to-kafka.conf | 10 +++++----- jdbc-to-elasticsearch.conf | 4 ++-- jms.conf | 4 ++-- kafka-to-elasticsearch.conf | 10 +++++----- pekko-connectors-sample-ftp-to-file/README.md | 4 ++-- pekko-connectors-sample-ftp-to-file/build.sbt | 2 +- .../project/Dependencies.scala | 15 +++++++-------- .../src/main/java/samples/javadsl/Main.java | 16 ++++++++-------- .../src/main/resources/application.conf | 6 +++--- .../src/main/resources/logback.xml | 2 +- .../src/main/scala/samples/scaladsl/Main.scala | 12 ++++++------ pekko-connectors-sample-http-csv-to-kafka/README.md | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../src/main/java/samples/javadsl/Main.java | 2 +- .../src/main/scala/samples/Main.scala | 2 +- .../README.md | 2 +- .../README.md | 2 +- pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt | 2 +- pekko-connectors-sample-mqtt-to-kafka/README.md | 2 +- pekko-connectors-sample-rotate-logs-to-ftp/README.md | 2 +- pekko-connectors-sample-rotate-logs-to-ftp/build.sbt | 2 +- 36 files changed, 76 insertions(+), 81 deletions(-) diff --git a/docs/build.sbt b/docs/build.sbt index c7446e1..9d9ad40 100644 --- a/docs/build.sbt +++ b/docs/build.sbt @@ -1,7 +1,7 @@ ThisBuild / scalaVersion := "2.13.12" -enablePlugins(AkkaParadoxPlugin, ParadoxSitePlugin, PublishRsyncPlugin) +enablePlugins(AkkaParadoxPlugin, ParadoxSitePlugin) name := "Pekko Connectors Samples" previewFixedPort := Some(8085) @@ -26,13 +26,13 @@ FtpToFile / paradoxProperties ++= Map( "snip.build.base_dir" -> s"${baseDirectory.value}/../pekko-connectors-sample-${FtpToFile.name}", "github.root.base_dir" -> s"${baseDirectory.value}/..", // Pekko Connectors - "scaladoc.akka.stream.alpakka.base_url" -> s"https://doc.akka.io/api/alpakka/${Dependencies.FtpToFile.PekkoConnectorsVersion}";, - "javadoc.akka.base_url" -> "", - "extref.alpakka.base_url" -> s"https://doc.akka.io/docs/alpakka/${Dependencies.FtpToFile.PekkoConnectorsVersion}/%s";, + "scaladoc.org.apache.pekko.stream.connectors.base_url" -> s"https://pekko.apache.org/api/pekko-connectors/${Dependencies.FtpToFile.PekkoConnectorsVersion}";, + "javadoc.org.apache.pekko.stream.connectors.base_url" -> "", + "extref.org.apache.pekko.stream.connectors.base_url" -> s"https://pekko.apache.org/docs/pekko-connectors/${Dependencies.FtpToFile.PekkoConnectorsVersion}/%s";, // Pekko - "scaladoc.akka.base_url" -> s"https://doc.akka.io/api/akka/${Dependencies.FtpToFile.PekkoVersion}";, - "javadoc.akka.base_url" -> s"https://doc.akka.io/japi/akka/${Dependencies.FtpToFile.PekkoVersion}";, - "extref.akka.base_url" -> s"https://doc.akka.io/docs/akka/${Dependencies.FtpToFile.PekkoVersion}/%s";, + "scaladoc.org.apache.pekko.base_url" -> s"https://pekko.apache.org/api/pekko/${Dependencies.FtpToFile.PekkoVersion}";, + "javadoc.org.apache.pekko.base_url" -> s"https://pekko.apache.org/japi/pekko/${Dependencies.FtpToFile.PekkoVersion}";, + "extref.org.apache.pekko.base_url" -> s"https://pekko.apache.org/docs/pekko/${Dependencies.FtpToFile.PekkoVersion}/%s";, ) FtpToFile / paradoxGroups := Map("Language" -> Seq("Java", "Scala")) @@ -259,6 +259,3 @@ paradoxProperties ++= Map( "extref.pekko.base_url" -> "https://pekko.apache.org/docs/pekko/current/";, "extref.pekko-connectors.base_url" -> "https://pekko.apache.org/docs/pekko-connectors/current/";, ) - -publishRsyncArtifacts += makeSite.value -> "akka.io/alpakka-samples/" -publishRsyncHost := "[email protected]" diff --git a/docs/project/plugins.sbt b/docs/project/plugins.sbt index be40904..bb8fb81 100644 --- a/docs/project/plugins.sbt +++ b/docs/project/plugins.sbt @@ -1,6 +1,5 @@ addSbtPlugin("com.lightbend.akka" % "sbt-paradox-akka" % "0.44") addSbtPlugin("com.typesafe.sbt" % "sbt-site" % "1.4.1") -addSbtPlugin("com.lightbend.sbt" % "sbt-publish-rsync" % "0.2") dependencyOverrides += "org.scala-lang.modules" %% "scala-xml" % "2.2.0" libraryDependencies += "org.scalameta" %% "scalameta" % "4.4.6" diff --git a/ftp-to-file.conf b/ftp-to-file.conf index 01984d0..ff311be 100644 --- a/ftp-to-file.conf +++ b/ftp-to-file.conf @@ -1,8 +1,8 @@ // https://github.com/lightbend-training/course-management-tools // // commands: -// linearize -f -cfg ftp-to-file.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized -// delinearize -cfg ftp-to-file.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized/alpakka-samples +// linearize -f -cfg ftp-to-file.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized +// delinearize -cfg ftp-to-file.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized/pekko-connectors-samples studentify { test-code-folders = [ @@ -12,11 +12,11 @@ studentify { exercise-project-prefix = "step" - master-base-project-name = "alpakka-sample-ftp-to-file_master" + master-base-project-name = "pekko-connectors-sample-ftp-to-file_master" - studentified-project-name = "alpakka-sample-ftp-to-file_sample" + studentified-project-name = "pekko-connectors-sample-ftp-to-file_sample" - relative-source-folder = "alpakka-sample-ftp-to-file" + relative-source-folder = "pekko-connectors-sample-ftp-to-file" readme-in-test-resources = false diff --git a/http-csv-to-kafka.conf b/http-csv-to-kafka.conf index e742850..d1c31c9 100644 --- a/http-csv-to-kafka.conf +++ b/http-csv-to-kafka.conf @@ -1,8 +1,8 @@ // https://github.com/lightbend-training/course-management-tools // // commands: -// linearize -f -cfg http-csv-to-kafka.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-linearized -// delinearize -cfg http-csv-to-kafka.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-linearized/alpakka-samples +// linearize -f -cfg http-csv-to-kafka.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-linearized +// delinearize -cfg http-csv-to-kafka.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-linearized/pekko-connectors-samples studentify { test-code-folders = [ @@ -12,11 +12,11 @@ studentify { exercise-project-prefix = "step" - master-base-project-name = "alpakka-sample-http-csv-to-kafka_master" + master-base-project-name = "pekko-connectors-sample-http-csv-to-kafka_master" - studentified-project-name = "alpakka-sample-http-csv-to-kafka_sample" + studentified-project-name = "pekko-connectors-sample-http-csv-to-kafka_sample" - relative-source-folder = "alpakka-sample-http-csv-to-kafka" + relative-source-folder = "pekko-connectors-sample-http-csv-to-kafka" readme-in-test-resources = false diff --git a/jdbc-to-elasticsearch.conf b/jdbc-to-elasticsearch.conf index 0fe9cf4..08e59f6 100644 --- a/jdbc-to-elasticsearch.conf +++ b/jdbc-to-elasticsearch.conf @@ -1,8 +1,8 @@ // https://github.com/lightbend-training/course-management-tools // // commands: -// linearize -f -cfg jdbc-to-elasticsearch.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized -// delinearize -cfg jdbc-to-elasticsearch.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized/alpakka-samples +// linearize -f -cfg jdbc-to-elasticsearch.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized +// delinearize -cfg jdbc-to-elasticsearch.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized/pekko-connectors-samples studentify { test-code-folders = [ diff --git a/jms.conf b/jms.conf index 53b6132..1ac9e7c 100644 --- a/jms.conf +++ b/jms.conf @@ -1,8 +1,8 @@ // https://github.com/lightbend-training/course-management-tools // // commands: -// linearize -f -cfg jms.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized -// delinearize -cfg jms.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized/alpakka-samples +// linearize -f -cfg jms.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized +// delinearize -cfg jms.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized/pekko-connectors-samples studentify { test-code-folders = [ diff --git a/kafka-to-elasticsearch.conf b/kafka-to-elasticsearch.conf index 0022727..d770f71 100644 --- a/kafka-to-elasticsearch.conf +++ b/kafka-to-elasticsearch.conf @@ -1,8 +1,8 @@ // https://github.com/lightbend-training/course-management-tools // // commands: -// linearize -f -cfg kafka-to-elasticsearch.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized -// delinearize -cfg kafka-to-elasticsearch.conf /Users/enno/dev/alpakka-samples /Users/enno/dev/alpakka-samples-lineraized/alpakka-samples +// linearize -f -cfg kafka-to-elasticsearch.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized +// delinearize -cfg kafka-to-elasticsearch.conf /Users/enno/dev/pekko-connectors-samples /Users/enno/dev/pekko-connectors-samples-lineraized/pekko-connectors-samples studentify { test-code-folders = [ @@ -12,11 +12,11 @@ studentify { exercise-project-prefix = "step" - master-base-project-name = "alpakka-sample-kafka-to-elasticsearch_master" + master-base-project-name = "pekko-connectors-sample-kafka-to-elasticsearch_master" - studentified-project-name = "alpakka-sample-kafka-to-elasticsearch_sample" + studentified-project-name = "pekko-connectors-sample-kafka-to-elasticsearch_sample" - relative-source-folder = "alpakka-sample-kafka-to-elasticsearch" + relative-source-folder = "pekko-connectors-sample-kafka-to-elasticsearch" readme-in-test-resources = false diff --git a/pekko-connectors-sample-ftp-to-file/README.md b/pekko-connectors-sample-ftp-to-file/README.md index 3b6cf69..8392456 100644 --- a/pekko-connectors-sample-ftp-to-file/README.md +++ b/pekko-connectors-sample-ftp-to-file/README.md @@ -2,8 +2,8 @@ ## Download all files an FTP server to local files -This example uses @extref[Alpakka FTP](alpakka:ftp.html) to read from the FTP server, and stores files using Akka Stream `FileIO`. +This example uses @extref[Pekko Connectors FTP](pekko-connectors:ftp.html) to read from the FTP server, and stores files using Akka Stream `FileIO`. Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-ftp-to-file) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-ftp-to-file` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-ftp-to-file` directory. diff --git a/pekko-connectors-sample-ftp-to-file/build.sbt b/pekko-connectors-sample-ftp-to-file/build.sbt index 0b112ab..614f844 100644 --- a/pekko-connectors-sample-ftp-to-file/build.sbt +++ b/pekko-connectors-sample-ftp-to-file/build.sbt @@ -1,4 +1,4 @@ -organization := "com.lightbend.akka.samples" +organization := "org.apache.pekko" name := "pekko-connectors-sample-ftp-to-file" version := "1.0.0" scalaVersion := Dependencies.scalaVer diff --git a/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala b/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala index 2180918..d92d8b6 100644 --- a/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala +++ b/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala @@ -3,25 +3,24 @@ import sbt._ object Dependencies { val scalaVer = "2.13.12" // #deps - val PekkoVersion = "2.6.19" - val PekkoConnectorsVersion = "4.0.0" + val PekkoVersion = "1.0.2" + val PekkoConnectorsVersion = "1.0.1" // #deps val dependencies = List( // #deps - "com.typesafe.akka" %% "akka-stream" % PekkoVersion, - "com.lightbend.akka" %% "akka-stream-alpakka-ftp" % PekkoConnectorsVersion, - "com.typesafe.akka" %% "akka-stream" % PekkoVersion, - "com.typesafe.akka" %% "akka-actor-typed" % PekkoVersion, - "com.typesafe.akka" %% "akka-actor" % PekkoVersion, + "org.apache.pekko" %% "pekko-stream" % PekkoVersion, + "org.apache.pekko" %% "pekko-connectors-ftp" % PekkoConnectorsVersion, + "org.apache.pekko" %% "pekko-actor-typed" % PekkoVersion, + "org.apache.pekko" %% "pekko-actor" % PekkoVersion, // #deps // Playground file system and FTP server // https://mina.apache.org/ftpserver-project/downloads.html "org.apache.ftpserver" % "ftpserver-core" % "1.1.1", // ApacheV2 "com.google.jimfs" % "jimfs" % "1.1", // ApacheV2 // Logging - "com.typesafe.akka" %% "akka-slf4j" % PekkoVersion, + "org.apache.pekko" %% "pekko-slf4j" % PekkoVersion, "ch.qos.logback" % "logback-classic" % "1.2.13" ) } diff --git a/pekko-connectors-sample-ftp-to-file/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-ftp-to-file/src/main/java/samples/javadsl/Main.java index a8dcc60..f954a5d 100644 --- a/pekko-connectors-sample-ftp-to-file/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-ftp-to-file/src/main/java/samples/javadsl/Main.java @@ -1,14 +1,14 @@ package samples.javadsl; -import akka.actor.typed.ActorSystem; -import akka.actor.typed.javadsl.Behaviors; -import akka.japi.Pair; -import akka.stream.IOResult; +import org.apache.pekko.actor.typed.ActorSystem; +import org.apache.pekko.actor.typed.javadsl.Behaviors; +import org.apache.pekko.japi.Pair; +import org.apache.pekko.stream.IOResult; // #imports -import akka.stream.alpakka.ftp.FtpSettings; -import akka.stream.alpakka.ftp.javadsl.Ftp; -import akka.stream.javadsl.FileIO; -import akka.stream.javadsl.Sink; +import org.apache.pekko.stream.connectors.ftp.FtpSettings; +import org.apache.pekko.stream.connectors.ftp.javadsl.Ftp; +import org.apache.pekko.stream.javadsl.FileIO; +import org.apache.pekko.stream.javadsl.Sink; // #imports import org.apache.ftpserver.FtpServer; import org.apache.mina.util.AvailablePortFinder; diff --git a/pekko-connectors-sample-ftp-to-file/src/main/resources/application.conf b/pekko-connectors-sample-ftp-to-file/src/main/resources/application.conf index 7bdde8d..77117b1 100644 --- a/pekko-connectors-sample-ftp-to-file/src/main/resources/application.conf +++ b/pekko-connectors-sample-ftp-to-file/src/main/resources/application.conf @@ -1,5 +1,5 @@ -akka { - loggers = ["akka.event.slf4j.Slf4jLogger"] - logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" +pekko { + loggers = ["org.apache.pekko.event.slf4j.Slf4jLogger"] + logging-filter = "org.apache.pekko.event.slf4j.Slf4jLoggingFilter" loglevel = "DEBUG" } diff --git a/pekko-connectors-sample-ftp-to-file/src/main/resources/logback.xml b/pekko-connectors-sample-ftp-to-file/src/main/resources/logback.xml index 90fd9ea..088957d 100644 --- a/pekko-connectors-sample-ftp-to-file/src/main/resources/logback.xml +++ b/pekko-connectors-sample-ftp-to-file/src/main/resources/logback.xml @@ -8,7 +8,7 @@ </appender> <logger name="slick" level="INFO"/> - <logger name="akka.stream.alpakka.ftp" level="INFO"/> + <logger name="org.apache.pekko" level="INFO"/> <logger name="org.apache.mina" level="INFO"/> <logger name="org.apache.ftpserver" level="INFO"/> <logger name="org.apache.ftpserver.listener" level="WARN"/> diff --git a/pekko-connectors-sample-ftp-to-file/src/main/scala/samples/scaladsl/Main.scala b/pekko-connectors-sample-ftp-to-file/src/main/scala/samples/scaladsl/Main.scala index c333ac1..449cef5 100644 --- a/pekko-connectors-sample-ftp-to-file/src/main/scala/samples/scaladsl/Main.scala +++ b/pekko-connectors-sample-ftp-to-file/src/main/scala/samples/scaladsl/Main.scala @@ -3,13 +3,13 @@ package samples.scaladsl import java.net.InetAddress import java.nio.file.Paths -import akka.actor.typed.ActorSystem -import akka.actor.typed.scaladsl.Behaviors +import org.apache.pekko.actor.typed.ActorSystem +import org.apache.pekko.actor.typed.scaladsl.Behaviors // #imports -import akka.stream.alpakka.ftp.FtpSettings -import akka.stream.alpakka.ftp.scaladsl.Ftp -import akka.stream.scaladsl.{FileIO, Sink} -import akka.stream.IOResult +import org.apache.pekko.stream.connectors.ftp.FtpSettings +import org.apache.pekko.stream.connectors.ftp.scaladsl.Ftp +import org.apache.pekko.stream.scaladsl.{FileIO, Sink} +import org.apache.pekko.stream.IOResult // #imports import org.apache.mina.util.AvailablePortFinder import playground.FtpServerEmbedded diff --git a/pekko-connectors-sample-http-csv-to-kafka/README.md b/pekko-connectors-sample-http-csv-to-kafka/README.md index 98094dd..2327648 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/README.md +++ b/pekko-connectors-sample-http-csv-to-kafka/README.md @@ -6,4 +6,4 @@ This example uses @extref[Akka HTTP to send the HTTP request](akka-http:client-s Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-http-csv-to-kafka) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-http-csv-to-kafka` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-http-csv-to-kafka` directory. diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_001_http_request/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_001_http_request/src/main/scala/samples/Main.scala index b2a695e..be7ab9a 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_001_http_request/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_001_http_request/src/main/scala/samples/Main.scala @@ -18,7 +18,7 @@ import scala.concurrent.Future object Main extends App { - implicit val actorSystem = ActorSystem("alpakka-samples") + implicit val actorSystem = ActorSystem("pekko-connectors-samples") import actorSystem.dispatcher diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/java/samples/javadsl/Main.java index 7b2f5df..d9e9207 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/java/samples/javadsl/Main.java @@ -43,7 +43,7 @@ public class Main { } private void run() throws Exception { - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); CompletionStage<Done> completion = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/scala/samples/Main.scala index 1aeb231..52fd128 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_002_extract_http_entity/src/main/scala/samples/Main.scala @@ -19,7 +19,7 @@ import scala.concurrent.Future object Main extends App { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/java/samples/javadsl/Main.java index 4df410b..52e7fa6 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/java/samples/javadsl/Main.java @@ -46,7 +46,7 @@ public class Main { } private void run() throws Exception { - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); CompletionStage<Done> completion = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/scala/samples/Main.scala index a23e20d..f0e3811 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_003_parse_csv/src/main/scala/samples/Main.scala @@ -20,7 +20,7 @@ import scala.concurrent.Future object Main extends App { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/java/samples/javadsl/Main.java index 40bf270..2d54750 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/java/samples/javadsl/Main.java @@ -70,7 +70,7 @@ public class Main { } private void run() throws Exception { - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); CompletionStage<Done> completion = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/scala/samples/Main.scala index 24bfe81..869fccc 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_004_producing_json/src/main/scala/samples/Main.scala @@ -23,7 +23,7 @@ object Main extends App with DefaultJsonProtocol { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/java/samples/javadsl/Main.java index 2593daf..6bc7588 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/java/samples/javadsl/Main.java @@ -79,7 +79,7 @@ public class Main { } private void run() throws Exception { - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); CompletionStage<Done> completion = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/scala/samples/Main.scala index 35254af..49abce9 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_005_cleanse_lines/src/main/scala/samples/Main.scala @@ -23,7 +23,7 @@ object Main extends App with DefaultJsonProtocol { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/java/samples/javadsl/Main.java index 8a16ad9..0b446c8 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/java/samples/javadsl/Main.java @@ -80,7 +80,7 @@ public class Main { } private void run() throws Exception { - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); CompletionStage<Done> completion = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/scala/samples/Main.scala index 13c3d44..606692a 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_006_coordinated_shutdown/src/main/scala/samples/Main.scala @@ -24,7 +24,7 @@ object Main extends App with DefaultJsonProtocol { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/java/samples/javadsl/Main.java index 0960ea5..e6d6e9c 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/java/samples/javadsl/Main.java @@ -96,7 +96,7 @@ public class Main { kafkaBroker.start(); final String bootstrapServers = kafkaBroker.getBootstrapServers(); - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); ProducerSettings<String, String> kafkaProducerSettings = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/scala/samples/Main.scala index b3f6684..acb7c42 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_007_produce_to_kafka/src/main/scala/samples/Main.scala @@ -30,7 +30,7 @@ object Main extends App with DefaultJsonProtocol { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/java/samples/javadsl/Main.java b/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/java/samples/javadsl/Main.java index 73bc515..935a60e 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/java/samples/javadsl/Main.java +++ b/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/java/samples/javadsl/Main.java @@ -100,7 +100,7 @@ public class Main { kafkaBroker.start(); final String bootstrapServers = kafkaBroker.getBootstrapServers(); - ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "alpakka-samples"); + ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "pekko-connectors-samples"); Http http = Http.get(toClassic(system)); ProducerSettings<String, String> kafkaProducerSettings = diff --git a/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/scala/samples/Main.scala b/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/scala/samples/Main.scala index d148ad3..7297628 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/scala/samples/Main.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/step_008_scheduled_download/src/main/scala/samples/Main.scala @@ -33,7 +33,7 @@ object Main extends App with DefaultJsonProtocol { - implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "alpakka-samples") + implicit val actorSystem: ActorSystem[Nothing] = ActorSystem[Nothing](Behaviors.empty, "pekko-connectors-samples") import actorSystem.executionContext diff --git a/pekko-connectors-sample-kafka-to-elasticsearch/README.md b/pekko-connectors-sample-kafka-to-elasticsearch/README.md index 1c4b93e..865e3ff 100644 --- a/pekko-connectors-sample-kafka-to-elasticsearch/README.md +++ b/pekko-connectors-sample-kafka-to-elasticsearch/README.md @@ -6,4 +6,4 @@ This example uses @extref[Alpakka Kafka](alpakka-kafka:) to subscribe to a Kafka Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-kafka-to-elasticsearch) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-kafka-to-elasticsearch` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-kafka-to-elasticsearch` directory. diff --git a/pekko-connectors-sample-kafka-to-websocket-clients/README.md b/pekko-connectors-sample-kafka-to-websocket-clients/README.md index 7d0eb55..a18b177 100644 --- a/pekko-connectors-sample-kafka-to-websocket-clients/README.md +++ b/pekko-connectors-sample-kafka-to-websocket-clients/README.md @@ -6,7 +6,7 @@ Clients may connect via websockets and will receive data read from a Kafka topic Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-kafka-to-websocket-clients) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-kafka-to-websocket-clients` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-kafka-to-websocket-clients` directory. ## Running diff --git a/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt b/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt index e860ee7..bdbdc20 100644 --- a/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt +++ b/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt @@ -1,4 +1,4 @@ -organization := "com.lightbend.akka.samples" +organization := "org.apache.pekko" name := "pekko-connectors-samples-mqtt-http-to-s3-java" ThisBuild / scalaVersion := "2.13.12" diff --git a/pekko-connectors-sample-mqtt-to-kafka/README.md b/pekko-connectors-sample-mqtt-to-kafka/README.md index e987e34..8cf3e3c 100644 --- a/pekko-connectors-sample-mqtt-to-kafka/README.md +++ b/pekko-connectors-sample-mqtt-to-kafka/README.md @@ -6,4 +6,4 @@ Subscribe to an MQTT topic with @extref[Alpakka MQTT](alpakka:/mqtt.html), group Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-mqtt-to-kafka) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-mqtt-to-kafka` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-mqtt-to-kafka` directory. diff --git a/pekko-connectors-sample-rotate-logs-to-ftp/README.md b/pekko-connectors-sample-rotate-logs-to-ftp/README.md index fc0636e..573052d 100644 --- a/pekko-connectors-sample-rotate-logs-to-ftp/README.md +++ b/pekko-connectors-sample-rotate-logs-to-ftp/README.md @@ -6,4 +6,4 @@ This example reads a stream of data and uses @extref[Alpakka File](alpakka:file. Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-rotate-logs-to-ftp) { open=new }. -To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `alpakka-sample-rotate-logs-to-ftp` directory. +To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-rotate-logs-to-ftp` directory. diff --git a/pekko-connectors-sample-rotate-logs-to-ftp/build.sbt b/pekko-connectors-sample-rotate-logs-to-ftp/build.sbt index 2ef94f2..47329e0 100644 --- a/pekko-connectors-sample-rotate-logs-to-ftp/build.sbt +++ b/pekko-connectors-sample-rotate-logs-to-ftp/build.sbt @@ -1,4 +1,4 @@ -organization := "com.lightbend.akka.samples" +organization := "org.apache.pekko" name := "pekko-connectors-sample-rotate-logs-to-ftp" version := "1.0.0" scalaVersion := Dependencies.scalaVer --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
