kafka

Export network flows from Kafka to Prometheus

A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry

Apache Kafka® extension for Visual Studio Code

JUnit rule for spinning up a Kafka broker

A Mysql data to file/elasticsearch/kafka/redis/redis-cluster/mongodb(audit and normal)/TiDB/postgresql with binlog tool.

kafka-go-example 以及系列教程

Protobuf converter plugin for Kafka Connect

Terraform provider for managing Apache Kafka Connect

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.

The goal of this project is to implement a "News" processing pipeline composed of five Spring Boot applications: producer-api, categorizer-service, co...

An Avro implementation for .NET

Dumps state of Storm Kafka consumers

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

Functional programming with Kafka and Scala

Snowflake Kafka Connector (Sink Connector)

Go-CQRS-EventSourcing-Microservice

Kafkawize : A Self service Apache Kafka Topic Management tool/portal. A Web application which automates the process of creating and browsing Kafka top...

Generate authentic looking mock data based on a SQL, JSON or Avro schema and produce to Kafka in JSON or Avro format.

Kafka backed service library.

Microservices data exchange with change data capture and outbox pattern.

Manage Confluent Schema Registry subjects through Infrastructure as code

A distributed fake data generator based in Akka.

Web tool for operating kafka connect https://hub.docker.com/r/officialkakao/kafka-connect-web

Previously used repository for new Debezium modules and connectors in incubation phase (archived)

Development repository for the kafka cookbook

以Kafka为存储介质，提供异步Http RPC的中间件

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

Streaming application development and management system, based on Linkis and DSS, planning to provide the workflow-like graphical drag-and-drop develo...

Mirror of Linkedin's Camus

Exports logs and metrics from Citrix ADC to various observability tools

Simple Kafka transport for Symfony Messenger.

Kafka Connect Sink/Source for Twitter

JDBC driver for Apache Kafka

Kafta is a command line for managing Kafka clusters

turnstyl is an open-source ETL data integrity monitoring node package built to work with event and messaging brokers like Kafka

Real-Time Data Processing Pipeline & Visualization with Docker, Spark, Kafka and Cassandra

Simple Event Driven Microservices with Spring Cloud Stream

🎓 Ozon Go Course

:cn: MyDataHarbor是一个致力于解决任意数据源到任意数据源的分布式、高扩展性、高性能、事务级的数据同步中间件。帮助用户可靠、快速、稳定的对海量数据进行准...

docker 快速搭建稳定安全的开发/生产环境

大数据组件 All-in-One 的 Dockerfile

Deploy ELK stack and kafka with docker-compose

数据建设与大数据技术知识体系，包含hadoop、hive、spark、flink主流框架和系列框架，数据中台、数据湖、数据治理、数仓建设、数据化转型等

Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push mess...

golang kafka consumer group

Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can expr...

Golang MQTT Broker.

Showcases using Kafka with a producer (writes messages to PostgreSQL) and consumer in NodeJS.

Oracle database CDC (Change Data Capture)

k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond