Discover lightbend/reactive-integration-examples Open Source project

Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.

6,125

cloudflow

322

paradox

Markdown documentation

Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka

245

kafka-with-akka-streams-kafka-streams-tutorial

Thin Scala wrapper around Kafka Streams Java API

213

kafka-streams-scala

Library offering http based query on top of Kafka Streams Interactive Queries

191

kafka-streams-query

Run Akka Cluster applications in Kubernetes.

akka-cluster-operator

model-serving-tutorial

Code and presentation for Strata Model Serving tutorial

SSL configuration logic, extracted from Play's WS (for use in Akka et al).

ssl-config

reactive-streams-utils

This project is deprecated

service-locator-dns

A compiler plugin for generating doc’able Java source from Scala source

genjavadoc

Java and Scala SDKs for Kalix

kalix-jvm-sdk

Kubeflow example of machine learning/model serving

kubeflow-recommender

Jupyter Notebook

flink-k8s-operator

An example of building kubernetes operator (Flink) using Abstract operator's framework

A SBT resolver and publisher for Google Cloud Storage

sbt-google-cloud-storage

reactive-cli

JavaScript and TypeScript SDKs for Kalix

kalix-javascript-sdk

TypeScript

reactive-lib

sbt-reactive-app

Mesos Integration Tests on Docker/Ec2

mesos-spark-integration-tests

Docker image for Spark history server on Kubernetes

spark-history-server-docker

All sample applications for Fast Data Platform

fdp-sample-applications

Pipelines Example Applications

pipelines-examples

cinnamon-ui

Lightbend Cinnamon UI

microprofile-reactive-streams

Lightbend's implementation of the MicroProfile Reactive Messaging spec

microprofile-reactive-messaging

Lightbend Console Helm Charts

console-charts

flink-operator

Helm Chart for lyft/flinkk8soperator

Smarty

sbt-whitesource

An sbt plugin to keep your WhiteSource project up to date

akka-grpc-ddata-shopping-cart

Implementation of Model serving in pipelines

pipelines-model-serving

akka-grpc-hands-on

Akka gRPC Hands-On

Demo applications showcasing the Lightbend Platform

lb-demos

Experimental implementation of speculative model serving

fdp-speculative-model-serving

Support for writing Lagom documentation in Markdown

lightbend-markdown

Lightbend Telemetry Samples

telemetry-samples

A VS Code extension for developers building stateful serverless applications on Kalix

vscode-kalix-tools

TypeScript

sbt-bill-of-materials

Create 'Bill of Materials' (BOM) POM files from sbt for consumption in Maven and Gradle.

RSocket Ingress for cloudflow

RSocketCloudflow

A Paradox directive to include standardised project information into the generated documentation

sbt-paradox-project-info

Apidoc (javadoc and scaladoc) support for the project documentation tool paradox

sbt-paradox-apidoc

Set of applications to test the performances of Spark Streaming

spark-streaming-testbed

Collection of Knative examples using Scala

KnativeSamples

Community Supported Cloudflow integrations

cloudflow-contrib

Seldon Cloudflow Integration

seldoncloudflow

Jupyter Notebook

akka-operator-helm

Helm charts for Akka platform operator

Smarty

lightbend-orchestration-docs

Documentation for Lightbend Orchestration

A Paradox directive to show module's transitive dependencies in the Paradox generated documentation

sbt-paradox-dependencies

Implementation of dynamically controlled streams patterns

fdp-dynamically-controlled-streams

Presentation and exercise code for ML metadata tutorial

ML-metadata-tutorial

Example for setting up an Akka Cluster app to run in Kubernetes with Lightbend Console monitoring

antora-ui-lightbend-cloud-theme

CSS

akka-projection-grpc-benchmark

console-akka-cluster-example

Installation Scripts for Cloudflow

cloudflow-installer

kalix-trial-scala-shoppingcart

Run Kalix CLI commands in GitHub workflows

kalix-action

Dockerfile

akka-cluster-orchestration-example

sbt companion for Kubernetes and OpenShift

deckhand

reactive-app-maven-plugin

Provisioning solution for Akka Cloud Platform to supported cloud providers

akka-cloud-platform-deploy

TypeScript

homebrew-brew

Homebrew is a package manager for macOS which provides easy installation and update management of additional software. This Tap (repository) contains the Formulae for tools that Lightbend offers.

Ruby

kalix-value-entity.g8

This is an sbt template for setting up a Scala Kalix project with a Value Entity.

play-openshift-example

reactive-sandbox

reactive-cli-build

A flavour of sbt-paradox-project-info for Lightbend's use.

sbt-paradox-lightbend-project-info

An e-commerce example for Kalix

kalix-trial-java-shoppingcart

Lightbend Telemetry - public

telemetry

Cloudflow Helm repository

nfs

NFS server and PVC

Smarty

cloudflow-helm-charts

IBMIntegrationGluster

Gluster support for IBM integration

Sample JS project using Github Actions CI/CD support for Kalix

kalix-cicd-github-actions

JavaScript

monitoringsamples

Sample applications that can be used to test monitoring tools (Insight team)

This is a simple project to build Flink image with Prometheus jar out of the "standard" Flink images

flink-k8s-build

An sbt plugin that adds rsync capabilities to your project

akkaserverless-cicd-github-actions

JavaScript

sbt-publish-rsync

kalix-ws-loan-application-scala

Template for an Akkaserverless project with a service backed by a value entity

akkaserverless-value-entity.g8