kafka

DC/OS SDK is a collection of tools, libraries, and documentation for easy integration of technologies such as Kafka, Cassandra, HDFS, Spark, and Tenso...

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

.NET event stream projection and scheduling platform with CosmosDB, DynamoDB, EventStoreDB, message-db, Equinox and Kafka integrations

Build systems with Go examples

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this librar...

Backup and Restore for Apache Kafka

一个拿来即用的docker镜像大礼包，直接构建docker镜像环境(docker、dockerfile、k8s、helm、shell and so on )，Linux运维工具及脚本，K8S构建，各种环境构建部...

Apache Kafka on Docker

**Unofficial / Community** Kafka Connect MongoDB Sink Connector -> integrated 2019 into the official MongoDB Kafka Connector here: https://www.mongodb...

a command-line Protobuf parser with Kafka support and JSON output

支持MySQL、MongoDB数据变更订阅分发

Springboot、SpringCloud各种常用框架使用案例，完善的文档，致力于让开发者快速搭建基础环境并让应用跑起来，并提供丰富的使用示例供使用者参考，快速上手。

Samsara is a real-time analytics platform

Big Data Toolkit for the JVM

Syslog Collector written in Go, streams to Kafka 0.8

[Deprecated] Load data from Kafka to any data warehouse. BQ sink is being supported in Firehose now. https://github.com/odpf/firehose

A python wrapper for the KSQL REST API.

A set of tools and examples to run a flow-pipeline (sFlow, NetFlow)

This project provides Docker compose files to deploy an Apache Kafka platform with a monitoring stack using Prometheus and Grafana

❤for real-time DataOps - where the application and data fabric blends - Lenses

Cloud and on-premises automation for Kubernetes centered industrial grade solutions.

The goal of this project is to compare some Java Microservice Frameworks like: Quarkus, Micronaut and Spring Boot. For it, we will implement applicati...

An example Event-Driven application in Go built with Watermill library.

Golang Kafka consumer and producer example

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

Rdkafka extension stubs for your IDE. Always compatibile with the latest php-rdkafka version.

A Clojure DSL for Kafka Streams

MemQ is an efficient, scalable cloud native PubSub system

Demo saga pattern, outbox pattern using Spring Boot, Debezium, Kafka, Kafka Connect

Chaos Framework proposes a unified API for vendors to provide solutions to various aspects of performing the principles of chaos engineering in cloud-...

Metronome is a distributed and fault-tolerant event scheduler

Cross-vendor normalisation for network syslog messages, following the OpenConfig and IETF YANG models

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

Serverless multi-protocol + multi-destination event collection system.

​:star: 基于 vue springboot sa-token mybatis netty 开发的前后端分离并包含用户聊天、附件管理的RABC权限后台管理系统

Java-Spring-CRQS-Eventsourcing-Microservice

Kafka 0.8.0 broker implementation on top of Cloudflare Workers

This is Node.js server tidy template / boilerplate with Express (with asyncified handlers, custom error handler) framework and MongoDb. The server us...

Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.

is a library that makes it easier to interact with the Confluent schema registry

My own version of r/place, done in a weekend

Bro IDS Dockerfile

Fully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog post published...

eCommerce application is a platform where customers can find products, shop around using a cart, check out the products and initiate payments. It is u...

Ansible role for installing and configuring Apache Kafka on RedHat and Debian platforms.

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor