Repository Index

Reactive Kafka Client for Vert.x

Apache Kafka Client for Delphi

OCaml bindings for Kafka

• ocaml-bindings
• kafka
• librdkafka

Stream database events from PostgreSQL to Kafka

• postgresql
• events
• stream
• kafka

Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency

☝️ go-graphql subscription over Kafka/Redis/NSQ example

• go
• graphql
• graphql-subscriptions
• kafka

Stream Processing Made Easy

• machine-learning
• reactive-programming
• kafka
• reactive-systems

High performance Delphi client based on Librdkafka with full protocol support.

A JMeter plug-in that enables you to send test results to a Kafka server

• jmeter
• plugin
• jmeter-plugin
• kafka

The repository host gives no description.

Gatling plugin for Apache Kafka — produce, request-reply, and consume load testing with Avro, Protobuf, and Schema Registry support

• gatling
• kafka
• performance
• performance-testing

An open source event management platform focused on Hackathons

• event
• event-management-platform
• hackathon
• hackathons

Kafka library for Crystal. Uses librdkafka.

• crystal
• crystal-lang
• kafka
• librdkafka

kafka pascal, freepascal bindings using librdkafka and zeromq

Gatling plugin for Kafka

Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code

• business-process
• kafka
• kafka-streams
• micorservices

provides a Suricata Eve output for Kafka with Suricate Eve plugin

• suricata
• intrusion-detection

Apache Kafka Ada client library, based off of librdkafka

A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.

• go
• kafka
• message-broker
• opentelemetry

Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.

• actor-model
• apache-flink
• distributed-systems
• event-driven

AWS_MSK_IAM Authentication Plugin for Broadway Kafka

Json-values allows Java developers to harness the power of persistent data structures when working with JSON data, simplifying complex data manipulation. It provides a purely functional approach to JSON

• functional-programming
• java
• json
• json-generator