kafka

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

equivalent to kafka-connect :wrench: for nodejs :sparkles::turtle::rocket::sparkles:

Apache Spark and Apache Kafka integration example

The Immerok Apache Flink Cookbook is a collection of examples of Apache Flink applications in the format of "recipes". Each recipe explains how you ca...

Spring Cloud Micro Services with Eureka Discovery, Zuul Proxy, OAuth2 Security, Hystrix CircuitBreaker, Sleuth Zipkin, ELK Stack Logging, Kafka, Docke...

springcloud 微服务，Sring cloud Greenwich.SR1 spring boot 2.1.3.RELEASE 版本 。服务水平加垂直分层，集成xxl-job定时任务系统、Redis缓存、队列、分布式锁...

OpenTracing Instrumentation for Apache Kafka Client

A Series of Notebooks on how to start with Kafka and Python

Kafka Connect Tooling

Yelper recommendation system

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

A REPL for Apache Kafka

Real-time Data Warehouse with Apache Flink & Apache Kafka & Apache Hudi

This is a Platform that collects all the data accuring in your Application and shows the data in real time by using Kibana or other tools.

Repo that relates to the Medium blog 'Keeping your ML model in shape with Kafka, Airflow' and MLFlow'

Kafka extension for Azure Functions

All are realtime interview questions and answers. I am adding more on daily basis whenever I am getting time.

Gradle plugin to interact with Confluent Schema-Registry.

基于开源Litemall电商项目的大数据项目，包含前端埋点(openresty+lua)、后端埋点；数据仓库(五层)、实时计算和用户画像。大数据平台采用CDH6.3.2(已使用vagrant+...

Java 核心技术,并发设计模式，数据结构与算法，SpringBoot ,OAuth2.0源码分析，Mysql进阶篇,Git 高级操作，Netty 教程，Redis设计与实战,Flink入门教程，Kafka入...

Distributed immutable data store with strong encryption and authentication

Project goal: Explore Kafka, Kafka Connect, and Kafka Streams. Components: store-api: Inserts/updates MySQL records. Source Connectors: Monitor MySQL...

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

KalDB is a cloud-native search and analytics engine for log, trace, and audit data

Simple URL shortener built with Fastify. Uses PostgreSQL, Redis, and Kafka.

Event sourcing journal implementation using Kafka as main storage

A Terraform provider for managing resource in confluent.cloud

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink b...

A web client for visualizing your Apache Kafka topics live.

📊 Monitoring examples for Confluent Cloud and Confluent Platform

Superman是什么：构建Java Android 高级开发技术的知识体系，从基础不断打怪升级成为超人之路（更新中.......）

Clojure client for Kafka

Kafka Connect FileSystem Connector

This is an example application to show howto use Spring Boot 3, Angular 20, Kafka with Streams and Mongodb with the reactive features of Spring in a c...

A high performance/ real-time C++ Kafka streams framework (C++17)

golang基础知识及实现，偏重于数据结构。另外包含web开源项目(中间件)的日常使用

关于kafka的一些相关使用示例代码。

One click deploy docker-compose with Kafka, Spark Streaming, Zeppelin UI and Monitoring (Grafana + Kafka Manager)

pastaʃ'ʃ = Spaghetti I/O Event Data Processing, Interpolation, Correlation and beyond :spaghetti:

The OEE-Designer is the build time environment for OEE applications.

Simple examle for Spark Streaming over Kafka topic

基于JavaScript Engine的轻量级规则引擎系统，重构于开源IOT项目thingboard

电影推荐系统、电影推荐引擎、使用Spark完成的电影推荐引擎

SQL Server Change Stream sample using Debezium

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

Clojure transducers interface to Kafka Streams

Zeek IDS Dockerfile

A full ecosystem that is built around kafka powered by golang