This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-samples.git
The following commit(s) were added to refs/heads/main by this push:
new 4f96138 migrate ftp sample (#17)
4f96138 is described below
commit 4f96138a8c8c9cec553f6a51856e1ef53c191270
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Dec 16 23:55:50 2023 +0100
migrate ftp sample (#17)
---
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]
