438 Open source projects that are alternatives of or similar to Pykafka

Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

A library that provides an in-memory Kafka instance to run your tests against.

Redpanda is the real-time engine for modern apps. Kafka API Compatible; 10x faster 🚀 See more at vectorized.io/redpanda

Apache Kafka support for Ruby Object Mapper

Modern and performant Kafka client library for Ruby based on librdkafka

Ansible playbooks for the Confluent Platform

Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

A lightweight stream processing library for Go

PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

提供各种客户端接入阿里云 消息队列 Kafka 的demo工程

A kafka command line browser

Kafka consumer lag monitor

A modern Apache Kafka client for node.js

SpringCloud构建实战、从入门到高级，包含eureka、zuul、gateway、feign、ribbon、hystrix、mq、turbine、nacos、elk、consul、zookeeper、rocketmq、kafka、分布式事务(RocketMq、LCN、Seata)、分库分表(Sharding-JDBC)、分布式锁(Redis、Guava)、jwt、SkyWalking、Zipkin、bootadmin等使用案例

汇总java生态圈常用技术框架、开源中间件，系统架构、数据库、大公司架构案例、常用三方类库、项目管理、线上问题排查、个人成长、思考等知识

gRPC/REST proxy for Kafka

Instagram Clone - Cloning Instagram for learning purpose

A resilient Ethereum event listener that bridges your smart contract events and backend microservices

Big Data Toolkit for the JVM

Distributed Stream and Batch Processing

Playground for Kafka/Confluent Docker experimentations

Kafka input and output plugin for Fluentd

Apache Kafka bridge

分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。

Secor is a service implementing Kafka log persistence

Divolte Collector

Node.js bindings for librdkafka

Kafka exporter for Prometheus

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

Terraform provider for managing Apache Kafka Topics + ACLs

Community driven, reusable components for distributed apps

java-study 是本人学习Java过程中记录的一些代码！从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设计模式示例代码、常用的工具类， 以及一些常用框架，netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等。

Metronome is a distributed and fault-tolerant event scheduler

本项目已迁移至 github.com/jetlinks

50+ DockerHub public images for Docker & Kubernetes - Hadoop, Kafka, ZooKeeper, HBase, Cassandra, Solr, SolrCloud, Presto, Apache Drill, Nifi, Spark, Consul, Riak, TeamCity and DevOps tools built on the major Linux distros: Alpine, CentOS, Debian, Fedora, Ubuntu

Python Stream Processing. A Faust fork

Kafka Source Connector For Oracle

Neo4j Kafka Integrations, Docs =>

程序员进阶书籍（视频），持续更新（Programmer Books）

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafka+微信支付宝支付gopay+api加密+api反向代理+go modules依赖管理+headless爬虫chromedp+makefile+二进制压缩+livereload热加载)

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.

Production-ready, stable Kafka client for PHP

Demo applications and code examples for Confluent Platform and Apache Kafka

Load data from Kafka to any data warehouse

kafka .net core library

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

dnc 去中心化 开源社区 轻联盟 dncto.com QQ群 779699538

docker compose files to create a fully working kafka stack

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

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, Landoop Tools, 20+ connectors

This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.

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

SpringBoot 整合各类框架和应用

Kalium: a reactive framework for micro-services

The purpose of this tiny project is to put things together with the know how that i learned from the course big data expert from formacionhadoop.com The idea is to show how to play with apache spark streaming, kafka,mongo, spark machine learning algorithms.

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

⚡️ Nepxion Thunder is a distribution RPC framework based on Netty + Hessian + Kafka + ActiveMQ + Tibco + Zookeeper + Redis + Spring Web MVC + Spring Boot + Docker 多协议、多组件、多序列化的分布式RPC调用框架

基于 scrapy-redis 的通用分布式爬虫框架

我的个人技术博客（Python、Django、Docker、Go、Redis、ElasticSearch、Kafka、Linux）