• Stars
    star
    1,418
  • Rank 32,033 (Top 0.7 %)
  • Language
    Scala
  • License
    Other
  • Created over 9 years ago
  • Updated 16 days ago

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Alpakka Kafka gh-actions-badge

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 Alpakka project is an open source initiative to implement stream-aware, reactive, integration pipelines for Java and Scala. It is built on top of Akka 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. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.

This repository contains the sources for the Alpakka Kafka connector. Which lets you connect Apache Kafka to Akka Streams. It was formerly known as Akka Streams Kafka and even Reactive Kafka.

Akka Stream connectors to other technologies are listed in the Alpakka repository.

Documentation

To keep up with the latest Alpakka releases check out Alpakka releases and Alpakka Kafka releases.

Community

You can join these groups and chats to discuss and ask Akka and Alpakka related questions:

In addition to that, you may enjoy following:

The Kafka connector was originally created as Reactive Kafka by SoftwareMill logo.

Contributing

The Akka family of projects is managed by teams at Lightbend with help from the community.

Contributions are very welcome! Lightbend appreciates community contributions by both those new to Alpakka and those more experienced.

Alpakka depends on the community to keep up with the ever-growing number of technologies with which to integrate. Please step up and share the successful Akka Stream integrations you implement with the Alpakka community.

If you find an issue that you'd like to see fixed, the quickest way to make that happen is to implement the fix and submit a pull request.

Refer to the CONTRIBUTING.md file for more details about the workflow, and general hints on how to prepare your pull request.

You can also ask for clarifications or guidance in GitHub issues directly.

Caveat Emptor

Alpakka 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.

License

Akka is licensed under the Business Source License 1.1, please see the Akka License FAQ.

Tests and documentation are under a separate license, see the LICENSE file in each documentation and test root directory for details.

More Repositories

1

akka

Build highly concurrent, distributed, and resilient message-driven applications on the JVM
Scala
12,931
star
2

akka-http

The Streaming-first HTTP server/module of Akka
Scala
1,335
star
3

alpakka

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Scala
1,262
star
4

akka-samples

Akka Sample Projects
Scala
793
star
5

akka-grpc

Akka gRPC
Scala
430
star
6

akka-persistence-cassandra

A replicated Akka Persistence journal backed by Apache Cassandra
Scala
328
star
7

akka-persistence-jdbc

Asynchronously writes journal and snapshot entries to configured JDBC databases so that Akka Actors can recover state
Scala
302
star
8

akka-management

Akka Management is a suite of tools for operating Akka Clusters.
Scala
254
star
9

akka-meta

This repository is dedicated to high-level feature discussions and for persisting design decisions.
201
star
10

akka-stream-contrib

Add-ons to Akka Stream
Scala
172
star
11

akka-http-quickstart-scala.g8

Scala
126
star
12

akka-projection

Akka Projections is intended for building systems with the CQRS pattern, and facilitate in event-based service-to-service communication.
Scala
98
star
13

akka-persistence-dynamodb

DynamoDBJournal for Akka Persistence
Scala
85
star
14

akka-modules

Akka Modules Repository
Scala
67
star
15

alpakka-samples

Example projects building Reactive Integrations using Alpakka
Java
66
star
16

akka-guide

Examples how to implement Microservices using Akka
Java
60
star
17

akka-quickstart-scala.g8

A minimal seed template for an Akka with Scala build
Scala
56
star
18

akka-sample-cluster-kubernetes-scala

Example showing how to create an Akka Cluster on Kubernetes.
Scala
45
star
19

akka.io

The akka.io site
SCSS
43
star
20

akka-sample-cluster-kubernetes-java

Shell
29
star
21

akka-sample-cluster-docker-compose-scala

Scala
27
star
22

akka-grpc-sample-kubernetes-scala

Scala
25
star
23

akka-persistence-r2dbc

Scala
24
star
24

apps

Scala
23
star
25

akka-quickstart-java.g8

A minimal seed template for an Akka in Java
Java
20
star
26

akka-grpc-quickstart-scala.g8

A minimal seed template for an Akka gRPC with Scala build
Scala
20
star
27

akka-http-quickstart-java.g8

Java
18
star
28

akka-distributed-workers-scala.g8

Scala
17
star
29

akka-persistence-spanner

Spanner plugin for Akka Persistence
Scala
13
star
30

akka-sample-cluster-docker-compose-java

Java
9
star
31

akka-http-webgoat

Scala
9
star
32

akka-minion

Akka CI and Github minion
Scala
8
star
33

akka-sample-cluster-kubernetes-dns-java

Java
8
star
34

akka-edge-rs

Akka Edge support in Rust
Rust
8
star
35

akka-kubernetes-tests

Basic tests that show Akka Cluster and friends work on Kubernetes
Scala
7
star
36

akka-paradox

Akka Paradox theme and extensions
CSS
7
star
37

akka-grpc-quickstart-java.g8

Akka gRPC Quickstart for Java
Java
6
star
38

akka-microservices-seed-scala.g8

Akka Microservices Giter8 template
Scala
5
star
39

doc.akka.io

Backup of documentation
5
star
40

akka-diagnostics

Build highly concurrent, distributed, and resilient message-driven applications on the JVM
Scala
4
star
41

akka-dependencies

Maven "bill of materials" (BOM) for Akka releases
Scala
3
star
42

old-blog

Akka Team Blog
CSS
3
star
43

akka-upgrade-testing

Test rolling upgrades for Akka remote/cluster
Scala
2
star
44

akka-projection-testing

End-to-end testing of Projections
Scala
1
star
45

assembla-migration

Perl
1
star
46

.github

Akka's organisation-wide files
1
star