Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
-
Updated
Oct 10, 2024 - Scala
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Kafka client for functional streams for scala (fs2)
Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.
Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs
Tool that providing ability to access kafka data - query items in topics and kafka metadata
Kamon Integration for Kafka(Producers|Consumers|Streams)
A basic application to explain the use of Functional Kafka Streams with Scala using fs2-kafka library.
Wait for it.... Kafka Examples!
A simple proxy built atop Akka HTTP for Apache Kafka
Independent Spark applications & jobs to discover the various spark functionalities & kafka integrations
This is a sbt project to describes how to pull tweets from twitter and publish into Kafka.
Kafka consumer that is listening a topic, upon a new event arrive in that topic it will trigger several NLP processes to be able to respond that event via twitter api (update status method)
Add a description, image, and links to the kafka-client topic page so that developers can more easily learn about it.
To associate your repository with the kafka-client topic, visit your repo's landing page and select "manage topics."