Top 70 apache-kafka open source projects

Open-Source Web GUI for Apache Kafka Management

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud

Command Line Tool for managing Apache Kafka

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Example Code for Kafka Tutorials @ Learning Journal

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.

Kafka Tutorials microsite

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

Apache Kafka on Docker

An email automation solution, written in Golang.

WaterDrop is a standalone Karafka component library for generating Kafka messages

The Internals of Apache Kafka

Azure Event Hubs for Apache Kafka Ecosystems

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Kafka 한국 사용자 모임에서 운영하는 meetup repository

Event sourcing for Akka Streams

A REPL for Apache Kafka

Framework for Apache Kafka based Ruby and Rails applications development.

Object Detection and Analysis Made easy using Raspberry Pi, Apache Kafka, AWS Rekognition & Docker

Kattlo CLI Project

A curated list of Pulsar tools, integrations and resources.

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.

Materials (slides and code) for Kafka and Kafka Streams Workshop

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

Kafka command line tool that likes JSON

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

The Apache Kafka C/C++ library

The Confluent Platform Helm charts enable you to deploy Confluent Platform services on Kubernetes for development, test, and proof of concept environments.

Kafka-based Job Queue for Python

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

Code for Agile Data Science 2.0, O'Reilly 2017, Second Edition

Modern C++ Apache Kafka client library (wrapper for librdkafka)

Kafka Connect HDFS connector

A list about Apache Kafka

🚀 Web GUI for Kafka Cluster Management

Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

No description or website provided.

Firehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical storage systems.

Post: Tracing Kafka Applications

kafka .net core library

Kafka Python Fake Data Producer is a complete demo app allowing you to quickly produce a Python fake Pizza-based streaming dataset and push it to an Apache Kafka topic. It gives an example on how easy is to create great fake streaming data to feed Apache Kafka.

Kryptonite for Kafka is a client-side 🔒 field level 🔓 crypto library for Apache Kafka® currently focused on Kafka Connect scenarios. It's an ! UNOFFICIAL ! community project

A client UI to inspect Kafka topics, consume, produce and much more

This repository contains a set of examples to be used with Red Hat AMQ messaging suite components.

Open Source Computer Vision with TensorFlow, MiniFi, Apache NiFi, OpenCV, Apache Tika and Python For processing images from IoT devices like Raspberry Pis, NVidia Jetson TX1, NanoPi Duos and more which are equipped with attached cameras or external USB webcams, we use Python to interface via OpenCV and PiCamera. From there we run image processin…

Apache Pulsar Adapters

A Kafka source connector capturing Scylla CDC changes

A native Kafka protocol proxy for Apache Kafka

No description or website provided.

带中文代码注释 Mirror of Apache RocketMQ 源码解析：http://www.iocoder.cn/categories/RocketMQ/?github

A vault plugin for generating ACLs for dynamic users

Lego bricks to build Apache Kafka serializers and deserializers

Kafka Interceptor for Zipkin

esque - an operational kafka tool.

⚾ Streaming left joins in Kafka for change data capture

Pulsar IO Kafka Connector

Counting Tweets Per User in Real-Time

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.