kafka

基于Go语言gin框架搭建的可快速开发的微服务脚手架

:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 0...

DDD应用框架

Neo4j Kafka Connector

The source code of the book "Microservices Patterns (Chris Richardson)" and the personal study note of Eventuate Tram Framework (The whole solution...

我,请始皇[打钱]是一个前后端分离的工具人系统，项目采用 SpringBoot+Go+Vue 开发，项目加入常见的企业级应用所涉及到的技术点，例如 Redis、RabbitMQ 等(主要是...

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafk...

本人的RabbitMQ和Kafka详细笔记以及示例代码

程序员 学习资料，以及一些书籍电子书，如果对您有所帮助，还希望大家多多star，更多资料请关注《Java有货》微信公众号获取

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

light, fast, scalable, streaming microservices made easy

A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch

Snowflake Kafka Connector (Sink Connector)

Backup and Restore for Apache Kafka

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

This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka serv...

Golang Kafka consumer and producer example

Write your Spark data to Kafka seamlessly

OAuth2 support for Apache Kafka® to work with many OAuth2 authorization servers

Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors

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

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

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

js extensions for the open-telemetry project

Easy implementation of kafka consumer with built-in exception manager (kafka-cronsumer)

kafka-go-example 以及系列教程

Kafka ecosystem ... but step by step!

mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message

StreamLine - Streaming Analytics

PG数据同步工具（Java实现）

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

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

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

Интенсив «Kafka за 90 минут» для DevOpsConf 2023

Confluent REST Proxy for Kafka

all kinds of scrapy demo

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

An AsyncAPI Golang Code generator that generates all Go code from the broker to the application/user. Just plug your application to your favorite mess...

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

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

A python wrapper for the KSQL REST API.

The Apache Kafka Operations Platform. 🚀

Build systems with Go examples

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

An Avro implementation for .NET

In-Memory Analytics for Kafka using DuckDB

End to End testing of Web, API, Cloud, Events and Security

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