kafka

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Apollo graphql subscriptions over Kafka protocol

Sample application for Lightning Web Components and Salesforce Platform runtime and compute capabilities. Part of the sample gallery. Electric car man...

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

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

Neo4j Kafka Connector

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

DDD应用框架

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

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

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

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

Snowflake Kafka Connector (Sink Connector)

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

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

Backup and Restore for Apache Kafka

light, fast, scalable, streaming microservices made easy

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

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

Golang Kafka consumer and producer example

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

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...

Write your Spark data to Kafka seamlessly

INGenious Playwright Studio

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

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

Kafka ecosystem ... but step by step!

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

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

kafka-go-example 以及系列教程

js extensions for the open-telemetry project

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

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

StreamLine - Streaming Analytics

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

​: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.

Confluent REST Proxy for Kafka

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...

Kafka data generator and load testing tool - generate fake messages, simulate producers and consumers, test broker failures, and run chaos engineeri...

all kinds of scrapy demo

The Apache Kafka Operations Platform. 🚀

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

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

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

A python wrapper for the KSQL REST API.

Nyc_Taxi_Data_Pipeline - DE Project

In-Memory Analytics for Kafka using DuckDB