pekko-connectors - GitLite

KO | EN

gitlite — search

#python #react #typescript #rust #linux #docker #nodejs #macos #kubernetes #vue #security #mcp #ios #open-source

pekko-connectors

(★ 81)

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

파일 탐색기

최종 버전 다운로드 (.zip)

파일 수가 많아 일부만 표시됩니다. 전체 파일은 위 다운로드 버튼으로 확인해 주세요.

- - check-build-test.yml
  - dependency-graph.yml
  - format.yml
  - headers.yml
  - link-validator.yml
  - nightly-builds.yaml
  - nightly-pekko-1.0-builds.yaml
  - nightly-pekko-1.x-builds.yaml
  - publish-1.0-docs.yml
  - publish-1.1-docs.yml
  - publish-1.2-docs.yml
  - publish-1.3-docs.yml
  - publish-2.0-docs.yml
  - publish-nightly-1.4.yml
  - publish-nightly.yml
  - publish-on-demand.yml
  - stage-release-candidate.yml
- autolabeler.yml
- dependabot.yml
- - cache.xml
  - geode.sh
  - start-local.sh
- - application.conf
  - build-and-push.sh
  - Dockerfile
  - gke-auth-test-job.yaml
  - gke-full-feature-test-job.yaml
  - GkeAuthTest.scala
  - GkeFullFeatureTest.scala
- README.md
- FTPLicense.txt
- FTPNotice.txt
- GoogleCommonLicense.txt
- MqttStreamingLicense.txt
- PekkoConnectorsNotice.txt
- S3License.txt
- S3Notice.txt
- StandardLicense.txt
- AutomaticModuleName.scala
- build.properties
- Common.scala
- CopyrightHeader.scala
- CopyrightHeaderForBuild.scala
- Dependencies.scala
- LicenseReport.scala
- MetaInfLicenseNoticeCopy.scala
- PekkoCoreDependency.scala
- PekkoHttpDependency.scala
- plugins.sbt
- project-info.conf
- TestChanged.scala
- cat-log.sh
- create-slow-minio.sh
- ftp-servers.sh
- link-validator.conf
.asf.yaml
.git-blame-ignore-revs
.gitattributes
.gitignore
.jvmopts
.sbtopts
.scala-steward.conf
.scalafmt.conf
AGENTS.md
build.sbt
CHANGELOG.md
CLAUDE.md
CONTRIBUTING.md
contributor-advice.md
docker-compose.yml
LICENSE
NOTICE
README.md

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# Apache Pekko Connectors [![scaladex-badge][]][scaladex] [![maven-central-badge][]][maven-central] [![CI on GitHub actions](https://github.com/apache/pekko-connectors/actions/workflows/check-build-test.yml/badge.svg)](https://github.com/apache/pekko-connectors/actions/workflows/check-build-test.yml)[![Nightly Builds](https://github.com/apache/pekko-connectors/actions/workflows/nightly-builds.yaml/badge.svg)](https://github.com/apache/pekko-connectors/actions/workflows/nightly-builds.yaml)

[scaladex]:              https://index.scala-lang.org/apache/pekko-connectors
[scaladex-badge]:        https://index.scala-lang.org/apache/pekko-connectors/latest.svg
[maven-central]:         https://search.maven.org/#search%7Cga%7C1%7Cpekko-connectors
[maven-central-badge]:   https://maven-badges.sml.io/maven-central/org.apache.pekko/pekko-connectors-file_2.13/badge.svg

Systems don't come alone. In the modern world of microservices and cloud deployment, new components must interact with legacy systems, making integration an important key to success. Reactive Streams give us a technology-independent tool to let these heterogeneous systems communicate without overwhelming each other.

The Apache Pekko Connectors project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Pekko Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Pekko Streams is a [Reactive Streams](http://www.reactive-streams.org/) and JDK 9+ [java.util.concurrent.Flow](https://docs.oracle.com/javase/10/docs/api/java/util/concurrent/Flow.html)-compliant implementation and therefore [fully interoperable](https://pekko.apache.org/docs/pekko/current/general/stream/stream-design.html#interoperation-with-other-reactive-streams-implementations) with other implementations.

Pekko Connectors is a fork of [Alpakka](https://github.com/akka/alpakka) 4.0.0, prior to the Akka project's adoption of the Business Source License.

## Documentation

Apache Pekko Connectors are documented at https://pekko.apache.org/docs/pekko-connectors/current/.

To keep up with the latest releases check out [Pekko Connectors releases](https://pekko.apache.org/docs/pekko-connectors/current/release-notes/index.html) and [Pekko Connectors Kafka releases](https://pekko.apache.org/docs/pekko-connectors-kafka/current/release-notes/index.html).

## Building From Source

The build commands in the [pekko](https://github.com/apache/pekko?tab=readme-ov-file#building-from-source) repo are also useful here. Java 17 should work well for building from source with the main branch. Pekko 1.x is best built with Java 8. If you build with newer versions of Java, you will need to specify a number of `--add-opens` settings.

This repo contains shell scripts. These scripts are designed to help with the testing of Apache Pekko Connectors. Please avoid running the scripts without checking if you need to and try to understand what the script does first.

There are some binary files in this repo that are used in testing. These files do not contain compiled artifacts.

* file/src/test/resources/nested-sample.tar
* google-cloud-pub-sub-grpc/src/main/resources/GSR2.crt
* s3/src/test/resources/keystore.jks

## Running Tests

There are details in the [Contributing page](https://github.com/apache/pekko-connectors/blob/main/CONTRIBUTING.md). That page also has guidelines about how to prepare Pull Requests.

## Community

You can join these forums and chats to discuss and ask Pekko and Pekko connector related questions:

- [GitHub discussions](https://github.com/apache/pekko-connectors/discussions): for questions and general discussion.
- [Pekko users mailing list](https://lists.apache.org/list.html?users@pekko.apache.org): for Pekko Connectors usage discussions.
- [Pekko dev mailing list](https://lists.apache.org/list.html?dev@pekko.apache.org): for Pekko Connectors development discussions.
- [GitHub issues](https://github.com/apache/pekko-connectors/issues): for bug reports and feature requests. Please search the existing issues before creating new ones. If you are unsure whether you have found a bug, consider asking in GitHub discussions or the mailing list first.

## Contributing

Contributions are very welcome. If you have an idea on how to improve Pekko, don't hesitate to create an issue or submit a pull request.

See [CONTRIBUTING.md](https://github.com/apache/pekko-connectors/blob/main/CONTRIBUTING.md) for details on the development workflow and how to create your pull request.

## Code of Conduct

Apache Pekko is governed by the [Apache code of conduct](https://www.apache.org/foundation/policies/conduct.html). By participating in this project you agree to abide by its terms.

## License

Apache Pekko is available under the Apache License, version 2.0. See [LICENSE](https://github.com/apache/pekko-connectors/blob/main/LICENSE) file for details.

## Caveat Emptor

Pekko Connectors components are not always binary compatible between releases. API changes that are not backward compatible might be introduced as we refine and simplify based on your feedback. A module may be dropped in any release without prior deprecation.

Our goal is to improve the stability and test coverage for Pekko Connectors APIs over time.