sky-uk/fs2-kafka-topic-loader   0.1.0

Reads the contents of provided Kafka topics

pirum-systems/scala-kafka-client   2.5.0

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

trace4cats/trace4cats-avro-kafka   0.14.0

Avro Kafka Exporter and Consumer for Trace4Cats

codefeedr/codefeedr   0.1.10

CodeFeedr core infrastructure

microsoft/mobius   2.0.200

C# and F# language binding and extensions to Apache Spark

zalando-nakadi/kanadi   0.20.0

Kanadi is a Nakadi client for Scala

garyaiki/dendrites   0.6.3

Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.

azure/azure-event-hubs-spark   2.1.5

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

box-castle/router   1.0.3

Castle Router is an efficient implementation for querying data from Kafka

anicolaspp/minikaf   1.0.0

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

tripl-ai/arc-kafka-pipeline-plugin   1.15.1

Provides KafkaExtract, KafkaLoad and KafkaCommitExecute stages

otavia-projects/otavia   0.4.5

Your shiny new IO & Actor programming model!

permutive-engineering/prometheus4cats-contrib   3.0.0

Prometheus4Cats instumentation for thrid party libaries

glorat/eventstore-scala   0.2.1

Scala implementation of a port of Greg Young's .NET CQRS example backed with a Kafka back-end that acts as both the event store and message bus

jobial-io/scase   2.2.2

Run functional Scala code as a portable serverless function or microservice

locationtech/geomesa   5.1.0

GeoMesa is a suite of tools for working with big geo-spatial data in a distributed fashion.

akka/alpakka   6.0.2

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