Skip to content

Commit

Permalink
Pekko becomes a TLP (#32)
Browse files Browse the repository at this point in the history
  • Loading branch information
pjfanning authored Mar 22, 2024
1 parent 2c3cda8 commit aa5e8ac
Show file tree
Hide file tree
Showing 12 changed files with 23 additions and 33 deletions.
10 changes: 0 additions & 10 deletions DISCLAIMER

This file was deleted.

6 changes: 3 additions & 3 deletions docs/build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -5,16 +5,16 @@ enablePlugins(ParadoxPlugin, PekkoParadoxPlugin, ParadoxSitePlugin)

name := "Pekko Connectors Samples"
previewFixedPort := Some(8085)
scmInfo := Some(ScmInfo(url("https://github.com/apache/incubator-pekko-connectors-samples"), "[email protected]:apache/incubator-pekko-connectors-samples.git"))
homepage := Some(url("https://github.com/apache/incubator-pekko-connectors-samples"))
scmInfo := Some(ScmInfo(url("https://github.com/apache/pekko-connectors-samples"), "[email protected]:apache/pekko-connectors-samples.git"))
homepage := Some(url("https://github.com/apache/pekko-connectors-samples"))
description := "Example solutions for Enterprise Integrations using Pekko Connectors and Reactive Streams."
version := {
val time = java.time.LocalDateTime.now().withSecond(0).withNano(0)
java.time.format.DateTimeFormatter.ISO_DATE.format(time) + " " + java.time.format.DateTimeFormatter.ISO_TIME.format(time)
}
isSnapshot := true

pekkoParadoxGithub := Some("https://github.com/apache/incubator-pekko-connectors-samples")
pekkoParadoxGithub := Some("https://github.com/apache/pekko-connectors-samples")

val FtpToFile = config("ftp-to-file")
ParadoxPlugin.paradoxSettings(FtpToFile)
Expand Down
4 changes: 2 additions & 2 deletions docs/src/main/paradox/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,9 @@ Read a stream of data and store it zipped in rotating files on an SFTP server.
### @extref:[Subscribe to MQTT and produce to Kafka](mqtt-to-kafka:index.html)
Subscribe to an MQTT topic with @extref[Pekko Connectors MQTT](pekko-connectors:/mqtt.html), group a few values and publish the aggregate to a Kafka topic with @extref[Pekko Connectors Kafka](pekko-connectors-kafka:).

### @link:[Amazon SQS](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-sqs-java) { open=new }
### @link:[Amazon SQS](https://github.com/apache/pekko-connectors-samples/tree/main/pekko-connectors-sample-sqs-java) { open=new }
Listen to an Amazon SQS topic, enrich the message via calling an actor, publish a new message to SQS and acknowledge/delete the original message. (Java only)

### @link:[MQTT topic triggers file download which is uploaded to AWS S3](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-mqtt-http-to-s3-java) { open=new }
### @link:[MQTT topic triggers file download which is uploaded to AWS S3](https://github.com/apache/pekko-connectors-samples/tree/main/pekko-connectors-sample-mqtt-http-to-s3-java) { open=new }

Listen to a MQTT topic, download from the URL passed in the received message, and upload the data from that address to AWS S3. (Java only)
4 changes: 2 additions & 2 deletions pekko-connectors-sample-file-to-elasticsearch/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,6 @@ A summary of tailed log files is also logged, which includes the following field
4. Last updated timestamp
5. Total log lines parsed

Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-file-to-elasticsearch) { open=new }.
Browse the sources at @link:[Github](https://github.com/apache/pekko-connectors-samples/tree/main/pekko-connectors-sample-file-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 `pekko-connectors-sample-file-to-elasticsearch` directory.
To try out this project clone @link:[the Pekko Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-file-to-elasticsearch` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-ftp-to-file/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

This example uses @extref[Pekko Connectors FTP](pekko-connectors:ftp.html) to read from the FTP server, and stores files using Pekko 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 }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-ftp-to-file` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-ftp-to-file` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-http-csv-to-kafka/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

This example uses @extref[Pekko HTTP to send the HTTP request](pekko-http:client-side/connection-level.html#opening-http-connections) and Pekko HTTPs primary JSON support via @extref[Spray JSON](pekko-http:common/json-support.html#spray-json-support) (for Scala) or Jackson JSON (for Java) to convert the map into a JSON structure which gets published to a Kafka topic.

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 }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-http-csv-to-kafka` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-http-csv-to-kafka` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-jdbc-to-elasticsearch/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

This example uses @extref[Pekko-Connectors Slick](pekko-connectors:slick.html) to read from a database, and stores the data in Elasticsearch.

Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-jdbc-to-elasticsearch) { open=new }.
Browse the sources at @link:[Github](https://github.com/apache/pekko-connectors-samples/tree/main/pekko-connectors-sample-jdbc-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 `pekko-connectors-sample-jdbc-to-elasticsearch` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-jdbc-to-elasticsearch` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-jms/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

These examples show small usages of @extref[Pekko-Connector JMS](pekko-connectors:jms).

Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-jms) { open=new }.
Browse the sources at @link:[Github](https://github.com/apache/pekko-connectors-samples/tree/main/pekko-connectors-sample-jms) { open=new }.

To try out this project clone @link:[the Pekko-Connector Samples repository](https://github.com/apache/incubator-pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-jms` directory.
To try out this project clone @link:[the Pekko-Connector Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-jms` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-kafka-to-elasticsearch/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

This example uses @extref[Pekko-Connectors Kafka](pekko-connectors-kafka:) to subscribe to a Kafka topic, parses JSON into a data class and stores the object in Elasticsearch. After storing the Kafka offset is committed back to Kafka. This gives at-least-once semantics.

Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-kafka-to-elasticsearch) { open=new }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-kafka-to-elasticsearch` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-kafka-to-elasticsearch` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-kafka-to-websocket-clients/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@

Clients may connect via websockets and will receive data read from a Kafka topic. The websockets are implemented in @extref[Pekko HTTP](pekko-http:) and [Pekko-Connectors Kafka](pekko-connectors-kafka:) subscribes to the 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 }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-kafka-to-websocket-clients` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-kafka-to-websocket-clients` directory.

## Running

Expand Down
4 changes: 2 additions & 2 deletions pekko-connectors-sample-mqtt-to-kafka/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

Subscribe to an MQTT topic with @extref[Pekko-Connectors MQTT](pekko-connectors:/mqtt.html), group a few values and publish the aggregate to a Kafka topic with @extref[Pekko-Connectors Kafka](pekko-connectors-kafka:).

Browse the sources at @link:[Github](https://github.com/apache/incubator-pekko-connectors-samples/tree/main/pekko-connectors-sample-mqtt-to-kafka) { open=new }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-mqtt-to-kafka` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-mqtt-to-kafka` directory.
4 changes: 2 additions & 2 deletions pekko-connectors-sample-rotate-logs-to-ftp/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@

This example reads a stream of data and uses @extref[Pekko-Connectors File](pekko-connectors:file.html) `LogRotatorSink` to write multiple files which get rotated triggered by a rotation function, the files are zipped in-flow and written to an SFTP server with @extref[Pekko-Connectors FTP](pekko-connectors:ftp.html).

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 }.
Browse the sources at @link:[Github](https://github.com/apache/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 `pekko-connectors-sample-rotate-logs-to-ftp` directory.
To try out this project clone @link:[the Pekko-Connectors Samples repository](https://github.com/apache/pekko-connectors-samples) { open=new } and find it in the `pekko-connectors-sample-rotate-logs-to-ftp` directory.

0 comments on commit aa5e8ac

Please sign in to comment.