kafka
Repositories (1408)
本人的RabbitMQ和Kafka详细笔记以及示例代码
我,请始皇[打钱]是一个前后端分离的工具人系统，项目采用 SpringBoot+Go+Vue 开发，项目加入常见的企业级应用所涉及到的技术点，例如 Redis、RabbitMQ 等(主要是...
程序员 学习资料，以及一些书籍电子书，如果对您有所帮助，还希望大家多多star，更多资料请关注《Java有货》微信公众号获取
light, fast, scalable, streaming microservices made easy
The source code of the book "Microservices Patterns (Chris Richardson)" and the personal study note of Eventuate Tram Framework (The whole solution...
A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch
This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.
Write your Spark data to Kafka seamlessly
Golang Kafka consumer and producer example
Backup and Restore for Apache Kafka
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...
a command-line Protobuf parser with Kafka support and JSON output
OAuth2 support for Apache Kafka® to work with many OAuth2 authorization servers
Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.
kafka-go-example 以及系列教程
Generate authentic looking mock data based on a SQL, JSON or Avro schema and produce to Kafka in JSON or Avro format.
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
Snowflake Kafka Connector (Sink Connector)
js extensions for the open-telemetry project
mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message
StreamLine - Streaming Analytics
Kafka ecosystem ... but step by step!
PG数据同步工具（Java实现）
Easy implementation of kafka consumer with built-in exception manager (kafka-cronsumer)
:star: 基于 vue springboot sa-token mybatis netty 开发的前后端分离并包含用户聊天、附件管理的RABC权限后台管理系统
An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.
一个拿来即用的docker镜像大礼包，直接构建docker镜像环境(docker、dockerfile、k8s、helm、shell and so on )，Linux运维工具及脚本，K8S构建，各种环境构建部...
all kinds of scrapy demo
Интенсив «Kafka за 90 минут» для DevOpsConf 2023
Chaos Framework proposes a unified API for vendors to provide solutions to various aspects of performing the principles of chaos engineering in cloud-...
❤for real-time DataOps - where the application and data fabric blends - Lenses
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.
Confluent REST Proxy for Kafka
Streamline Apache Kafka with Conduktor Platform. 🚀
Build systems with Go examples
An Avro implementation for .NET
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...
**Unofficial / Community** Kafka Connect MongoDB Sink Connector -> integrated 2019 into the official MongoDB Kafka Connector here: https://www.mongodb...
Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this librar...
End to End testing of Web, API, Cloud, Events and Security
A Series of Notebooks on how to start with Kafka and Python
Spring template for a REST service designed with Hexagonal architecture
Demo saga pattern, outbox pattern using Spring Boot, Debezium, Kafka, Kafka Connect
This project provides Docker compose files to deploy an Apache Kafka platform with a monitoring stack using Prometheus and Grafana
In-Memory Analytics for Kafka using DuckDB
[Deprecated] Load data from Kafka to any data warehouse. BQ sink is being supported in Firehose now. https://github.com/odpf/firehose