GitHub topics: confluent-kafka
vdesabou/kafka-docker-playground
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
Language: Shell - Size: 165 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 737 - Forks: 221
ashrafali01/HateCrimesAnalysis
Hate Crimes Analysis is a real-time data streaming and transformation pipeline designed to analyze hate crime data from 2017 to 2025. The project leverages modern big data technologies—Confluent Kafka for real-time data ingestion, PySpark for data transformations, and AWS S3 for cloud-based storage in Parquet format.
Language: Python - Size: 726 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0
averemee-si/oracdc
Oracle database CDC (Change Data Capture)
Language: Java - Size: 6.17 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 121 - Forks: 41
kmcclellan/kafka-di
An extension of Confluent's Kafka client for use with Microsoft.Extensions.DependencyInjection (and friends).
Language: C# - Size: 153 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 14 - Forks: 6
AndriyKalashnykov/go-kafka-confluent-examples
Confluent Cloud Kafka examples in Go
Language: Shell - Size: 449 KB - Last synced at: about 5 hours ago - Pushed at: 9 days ago - Stars: 1 - Forks: 0
zillow/zkafka
An efficient and scalable library for stateless Kafka message processing written in Go
Language: Go - Size: 385 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 63 - Forks: 1
j3-signalroom/ccaf-tableflow-aws_glue-snowflake-kickstarter
This project demonstrates how to use Terraform to automate the enablement of Tableflow in a Kafka Topic. Additionally, it shows how to configure Snowflake with Terraform to query the Iceberg Tables as an External Table, using AWS Glue Data Catalog between Confluent Cloud and Snowflake, with an AWS S3 bucket serving as the storage location.
Language: HCL - Size: 39.7 MB - Last synced at: 5 days ago - Pushed at: 14 days ago - Stars: 0 - Forks: 0
miozilla/kafkaz00
kafkaz00 :kangaroo::zebra: : # apache kafka # confluent # zookeeper # gcp
Language: Java - Size: 0 Bytes - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 0 - Forks: 0
floydspace/effect-kafka
📨 Effectful Kafka
Language: TypeScript - Size: 364 KB - Last synced at: 8 days ago - Pushed at: 21 days ago - Stars: 15 - Forks: 2
Effiware/kafka-mocha
Embedded Kafka for Python - Testing library for confluent_kafka
Language: Python - Size: 630 KB - Last synced at: 27 days ago - Pushed at: 27 days ago - Stars: 9 - Forks: 2
hifly81/kafka-examples
Practical examples with Apache Kafka®
Language: Java - Size: 120 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 78 - Forks: 16
shiningflash/kafka-python-messaging-engine
A Python-based Kafka messaging engine with Avro serialization, Schema Registry integration, and Redpanda support for real-time data streaming.
Language: Python - Size: 33.2 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
j3-signalroom/cc-clients-python_lib
This library provides a collection of Python functions that interact with Confluent Cloud via its REST APIs.
Language: Python - Size: 3.56 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0
pranav-kural/plamatio-backend
Performant, Scalable, and Resilient Backend for Plamatio E-Commerce.
Language: Go - Size: 166 KB - Last synced at: 20 days ago - Pushed at: 9 months ago - Stars: 2 - Forks: 1
angusgyoung/gox
A small outbox publisher for Postgres/Kafka, with support for kafka-backed parallelisation and rebalancing.
Language: Go - Size: 167 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 3 - Forks: 0
j3-signalroom/kafka-topic_record_picker-python_app
Code that picks a Kafka record from a specific offset.
Language: HCL - Size: 1.08 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
tkukushkin/kafka-async
Thin async wrapper for Confluent Kafka Python Client
Language: Python - Size: 182 KB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
tkukushkin/kafka-stubs
Type stubs for Confluent Kafka Python Client.
Language: Python - Size: 41 KB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
hackolade/Avro
Hackolade(https://hackolade.com) plugin for Avro
Language: JavaScript - Size: 3.98 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 15
masesgroup/KEFCore
Entity Framework Core provider for Apache Kafka™
Language: C# - Size: 54.9 MB - Last synced at: 18 days ago - Pushed at: 20 days ago - Stars: 7 - Forks: 1
j3-signalroom/ccaf-housekeeping-python_lib
The CCAF Housekeeping Python Library is a CI/CD support tool designed to automate the teardown of a Flink table and its associated Kafka resources—such as topics and schemas—along with any long-running statements linked to it.
Language: Python - Size: 236 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0
mwn-san/confluent-kafka
Kafka CLI Tools, ksqlDB Stream and Table, Confluent Kafka Python Client, Security, Environment Confluent Platform
Language: Python - Size: 9.85 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0
muhkartal/sentinelAI-safetyMonitoring
A real-time intelligent surveillance system designed to detect human falls and anomalous behaviors using deep learning techniques. Includes automated alerting, a monitoring dashboard, and scalable deployment via Docker and Kubernetes.
Language: Python - Size: 362 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0
averemee-si/aws-secrets-manager-kafka
AWS Secrets Manager Config Provider for Apache Kafka
Language: Java - Size: 84 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0
addu390/django-kafka
Python Django as Producer and Consumer using Apache Kafka for content queue and Celery for task queue
Language: Python - Size: 29.3 KB - Last synced at: 3 months ago - Pushed at: over 4 years ago - Stars: 60 - Forks: 22
rodrigo-arenas/kafkaml-anomaly-detection
Project for real-time anomaly detection using Kafka and python
Language: Python - Size: 9.69 MB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 58 - Forks: 20
Muhammad-Talha4k/AQI-Forecasting-App
Machine Learning Operations (MLOps) application that predicts the Air Quality Index (AQI) for Lahore, Pakistan, using a 100% serverless stack.
Language: Python - Size: 64.5 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0
robooo/robotframework-ConfluentKafkaLibrary
Robot Framework keyword library wrapper for python confluent kafka
Language: Python - Size: 1020 KB - Last synced at: 2 days ago - Pushed at: 5 months ago - Stars: 36 - Forks: 12
likhithkp/ecommerce-order-managent-system
A scalable order management system built using Golang, Kafka, and PostgreSQL, following a microservices architecture. The system efficiently handles orders, payments, and inventory updates through event-driven communication.
Language: Go - Size: 36.1 KB - Last synced at: 5 days ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0
manuelarte/confluent-kafka-go Fork of confluentinc/confluent-kafka-go
Confluent's Apache Kafka Golang client
Language: HTML - Size: 416 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0
sheinbergon/ksql-python-ng Fork of bryanyang0528/ksql-python
Pythonic KSQL REST API - Next Gen.
Language: Python - Size: 321 KB - Last synced at: 30 days ago - Pushed at: 10 months ago - Stars: 3 - Forks: 1
burakugurr/basic-way-cdc-postgresql_to_minio
CDC Project PostgreSQL to Minio using Confluent Kafka
Language: HTML - Size: 387 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0
tahir007malik/produceConsumeKafka
This repository demonstrates how we can write producer and consumer code to load and consume data using confluent kafka topic.
Language: Python - Size: 290 KB - Last synced at: 3 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0
DataDog/datadog-kafka-connect-logs
A plugin for Kafka Connect to send Kafka records as logs to Datadog.
Language: Java - Size: 417 KB - Last synced at: 2 months ago - Pushed at: 5 months ago - Stars: 7 - Forks: 11
tahir007malik/ecommerceDataStreamingAnalytics
This repository features a production-grade data pipeline leveraging Confluent Kafka for real-time collection of e-commerce clickstream and user activity data.
Language: Jupyter Notebook - Size: 558 KB - Last synced at: 3 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0
AbdulRehman-z/kafka-golang-examples
Some basic use cases of kafka.
Language: Go - Size: 18.6 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0
kmcclellan/kafka-dataflow
An extension of Confluent's Kafka client for use with System.Threading.Tasks.Dataflow.
Language: C# - Size: 44.9 KB - Last synced at: 20 days ago - Pushed at: about 2 years ago - Stars: 11 - Forks: 0
kayvansol/kafka-sink
Kafka SQL Server Sink Connector
Language: C# - Size: 1.14 MB - Last synced at: 17 days ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0
kayvansol/kafka-source
Debezium Source Connector from SQL Server to Apache Kafka
Language: TSQL - Size: 544 KB - Last synced at: 3 months ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 1
rijkerd/word-count
Kafka ,Kafka Stream and Spring Boot
Language: Java - Size: 63.5 KB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0
bitrockteam/codemotion-demo-2024
Language: Kotlin - Size: 822 KB - Last synced at: 4 months ago - Pushed at: 6 months ago - Stars: 9 - Forks: 0
donMichaelL/theTrial
A microframework designed to provide a simple interface for interacting with Kafka
Language: Python - Size: 16.6 KB - Last synced at: 9 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0
stormaref/KafkaStorm
Simple .net client for Kafka based on Confluent.Kafka
Language: C# - Size: 59.6 KB - Last synced at: 20 days ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0
allamiro/Data-Pipelines
Every thing about designing installing and implementing data pipelines to include kafka zookeeper hadoop If you enjoy my content please consider supporting what I do Thank you.
Language: Jinja - Size: 4.48 MB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 1 - Forks: 0
caio-moliveira/sales-pipeline-project
This project demonstrates an end-to-end data pipeline, integrating cloud storage, data processing, and real-time visualization. It serves as a practical foundation for similar data engineering and analytics workflows.
Language: Python - Size: 412 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0
wallisonmoura/event-driven-architecture
Repository created to study EDA (Event Driven Architecture)
Language: Go - Size: 41 KB - Last synced at: 4 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0
syedhassaanahmed/spark-with-engineering-fundamentals
E2E Spark data pipelines with engineering fundamentals
Language: HCL - Size: 1.22 MB - Last synced at: 25 days ago - Pushed at: 8 months ago - Stars: 2 - Forks: 2
irfnd/irfandi-betest
Implementation for technical test Code.id
Language: TypeScript - Size: 157 KB - Last synced at: 3 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0
kaiwaehner/kafka-connect-iot-mqtt-connector-example
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
Language: Shell - Size: 500 KB - Last synced at: 8 months ago - Pushed at: over 5 years ago - Stars: 206 - Forks: 88
Gowtham1729/stream-top
Stream-Top is a real-time system resource monitoring tool that utilizes Apache Kafka to stream resource utilization data, enabling live visualization of resource usage from distributed systems. (Kafka Learning Project)
Language: Jupyter Notebook - Size: 69.3 KB - Last synced at: 1 day ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
siddharth-nandagopal/kafka-kraft-cluster
Language: Shell - Size: 12.7 KB - Last synced at: 4 months ago - Pushed at: 9 months ago - Stars: 0 - Forks: 0
Stefen-Taime/eventmusic
EventMusic Producer is a Dockerized application designed to read data and output them to a Kafka topic, using Avro schemas for data serialization. It integrates seamlessly with Kafka and the Schema Registry to manage the flow of event data linked to music event information.
Language: Python - Size: 38.1 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0
VeenaBhyrava/ordersDimModelling
Dimensional modelling of order transactions
Language: Python - Size: 17.6 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0
gyarsilalsolanki011/JournalApp
JouranalApp built using the Spring Boot framework and MongoDB database.
Language: Java - Size: 106 KB - Last synced at: 10 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0
openweb-nl/open-bank-mark
A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.
Language: Clojure - Size: 142 KB - Last synced at: 2 months ago - Pushed at: over 5 years ago - Stars: 89 - Forks: 15
emsalcengiz/random-data-generation
Generating random data with Apache Kafka
Language: Python - Size: 3.13 MB - Last synced at: 10 months ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0
ashkan90/confluent-kafka
ease of use kafka confluent
Language: Go - Size: 41 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0
ajithvcoder/Multivideo_Objectdetection_MLOPS_Project
Multi video offline streaming and Yolov8 object detection with Kafka, torch serve, AWS EC2
Language: Jupyter Notebook - Size: 93 MB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 1
mstrielnikov/KafkaDataPlatform
Language: HCL - Size: 38.1 KB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0
rbiedrawa/spring-kafka-streams-protobuf-testcontainers-demo
Account Service - Spring, Kafka Streams sample application that allows users to sign up and retrieve account details and statistics. This PoC demonstrates how to run multiple Kafka Streams instances (with different consumer groups) inside single Spring Boot application.
Language: Java - Size: 716 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 6 - Forks: 4
pennowtech/kafka-producer-consumer
Ready to user Kafka Producer and Consumer implemented in Python3
Language: Python - Size: 2.93 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 0
MihaiBogdanEugen/docker-confluent-kafka-connect
Docker Kafka Connect image for the Confluent Open Source Platform using Oracle JDK
Size: 39.1 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 3 - Forks: 1
rupeshtiwari/kafka-spark-streaming-avro-in-python
Streaming kafka events using Spark in avro format and saving the events in parquet format
Language: Python - Size: 38.1 KB - Last synced at: 3 days ago - Pushed at: about 3 years ago - Stars: 5 - Forks: 1
MonsieurBorges/kafka-docker
Deploy Apache Kafka using docker-compose
Language: Python - Size: 28.3 KB - Last synced at: 4 months ago - Pushed at: almost 2 years ago - Stars: 6 - Forks: 1
openweb-nl/kafka-graphql-examples
A platform to test solutions for using Kafka with Graphql
Language: Clojure - Size: 46.1 MB - Last synced at: 3 months ago - Pushed at: about 5 years ago - Stars: 60 - Forks: 11
rbiedrawa/kafka-monitoring
The goal of this project is to demonstrate different approaches how to monitor Apache Kafka ecosystem.
Language: Java - Size: 5.18 MB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 1
ankurbhambri/kafka_avro
Kafka Avro, Schema Registry, Confluent Rest Proxy Examples and Endpoints Using Landoop Kafka UI
Language: Shell - Size: 9.77 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0
PRODYNA/insights-kafka-demo
Demo app showing how to setup local configuration for kafka infrastructure (broker, zookeeper, schema registry) with a topic, producer and consumer.
Language: Java - Size: 5.78 MB - Last synced at: 16 days ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0
mcolomerc/terraform-confluent-kafka-cluster
Terraform module for Confluent Cloud Kafka clusters
Language: HCL - Size: 13.7 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
mcolomerc/cctools
Confluent migration tools
Language: Go - Size: 1.01 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 1
Nasruddin/data-streaming-kafka-protobuf-golang-java
Data streaming between Java and Golang service with Kafka using Protocol Buffers
Language: Java - Size: 67.4 KB - Last synced at: 4 months ago - Pushed at: almost 3 years ago - Stars: 2 - Forks: 0
osodevops/kafka-audit-security-acls
Testing the audit logging of Confluent Kafka security ACLs
Language: Shell - Size: 26.4 KB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 0
daniellavoie/confluent-platform-bosh-release
Bosh release for Confluent Platform
Language: HTML - Size: 94.7 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 6 - Forks: 2
javaHelper/Apache-Kafka-for-absolute-beginners
Udemy - Apache Kafka for absolute beginners
Language: Java - Size: 689 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
Shikha-code36/Real-Time-Stock-Price-Tracker-using-Kafka
A real time stock prices tracker using Kafka
Language: Python - Size: 7.81 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 1
ora0600/genai-with-confluent
Generative AI in realtime with Confluent Cloud.
Language: HCL - Size: 2.79 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 5 - Forks: 8
SAAD3XK/kafka-debezium-postgresql
An integration of Debezium PostgreSQL connectors with Kafka and Pyspark.
Language: Jupyter Notebook - Size: 27.3 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
confluentinc/terraform-provider-confluentcloud 📦
Confluent Cloud Terraform Provider is deprecated in favor of Confluent Terraform Provider
Language: Go - Size: 268 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 52 - Forks: 23
ctrl-hub/franz
Prometheus exporter for Kafka metrics, with a focus on Confluent Cloud
Language: Go - Size: 41 KB - Last synced at: 24 days ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0
pannoi/kafka-schema-operator
Operator to provide Kafka Schema in declarative way using KubernetesCustomResources
Language: Go - Size: 74.2 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 1
harshit-budhraja/kafka_handler
A simple Kafka wrapper based on confluent_kafka python client.
Language: Python - Size: 26.4 KB - Last synced at: 3 days ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0
simplesteph/kafka-avro-course
Learn the Confluent Schema Registry & REST Proxy
Language: Java - Size: 30.3 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 182 - Forks: 199
apanjain/ML-Ops
End-to-end solution for training and using ML models in production.
Language: Python - Size: 496 KB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 0 - Forks: 1
PlantUp/kafkaesque
This is a simple package for using Kafka in Golang with the Observer-pattern.
Language: Go - Size: 56.6 KB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 0
Dudssource/jkafkacat
JKafkacat, a simple tool (inspired by kafkacat) to produce/consume messages from Apache Kafka
Language: Java - Size: 12.7 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 1
alexluix/ud-data-streaming-kafka-streaming
Udacity Data Streaming Nanodegree : Optimizing Public Transport
Language: Python - Size: 324 KB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0
mwn-san/Confluent
Encompassed here are pivotal insights on Kafka, poised to empower and greatly benefit a multitude, fostering harmony among fellow MWN aficionados
Language: Shell - Size: 65.4 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
osodevops/confluent-kubernetes-playground
Playground for Kafka / Confluent Kubernetes experimentations
Language: Python - Size: 5.99 MB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 15 - Forks: 5
dhohirpradana/ubuntu-kafka
Ubuntu with Kafka Installed
Size: 30.3 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 0
hooniegit/python-kafka
Use Python Module 'confluent_kafka' To Study Kafka Logics
Language: Python - Size: 6.84 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
Rohii1515/kafka-pipeline
This Confluent Kafka Pipeline project is designed to ingest data from sensors, process it using Kafka Streams, and then store the processed data in MongoDB. It provides a structured data pipeline for real-time data processing and storage.
Language: Jupyter Notebook - Size: 10.1 MB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
caard0s0/home-broker-system
Backend Microservice. Home Broker algorithm for Investment Brokers.
Language: Go - Size: 18.6 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
zakhaev26/microservices-go
Attempt to make a Hyper processing microservice using Apache Kafka
Language: Go - Size: 28.3 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
xuyaoqiang/kale
Kafka-based Distributed Task Queue for Python
Size: 0 Bytes - Last synced at: over 1 year ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 0
abhishekvermax/Confluent-KAFKA-java-client
Production based Confluent KAFKA client manager for consumer, admin and other stuffs using single fat JAR.
Language: Java - Size: 53.7 KB - Last synced at: over 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0
grongor/php-kafka-rest-client
PHP client for Confluent REST Proxy of Apache Kafka
Language: PHP - Size: 43.9 KB - Last synced at: 7 days ago - Pushed at: 5 months ago - Stars: 8 - Forks: 2
Team-Triage/triage
Triage is an open-source consumer proxy that solves head-of-line blocking for Kafka consumers
Language: Go - Size: 21.5 MB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 7 - Forks: 0
sckv/kafka-confluent-avro
Kafka Confluent Registry integration for encoding and decoding messages, only supports AVRO and intelligently retries schema encoding with previous versions.
Language: TypeScript - Size: 435 KB - Last synced at: 6 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 1
ozguramac/penr-oz-kafka-spring-json
Connect to Kafka using Spring in JSON format
Language: Java - Size: 55.7 KB - Last synced at: over 1 year ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0
rishabh96b/kafka-perf-test
Kafka performance testing tool to test your Kubernetes, DC/OS, and On-Prem/Local Kafka Clusters.
Language: Dockerfile - Size: 20.5 KB - Last synced at: 3 months ago - Pushed at: over 4 years ago - Stars: 8 - Forks: 7
