kafka

Social Record - Distributed scraping and analysis pipeline for a range of social media platforms

Kafka listener and producer above sarama and sarama-cluster

A convenience library for Apache Kafka integration in a Dropwizard service.

R client for Apache Kafka

Advanced Cloud Native Go - Packt Publishing Video Course

An Ansible framework for building cool things with AWS

Freestyle Kafka

spring boot kafka websocket demo

Sample microservices written using Micronaut framework communicating asynchronously through Apache Kafka

Slides, Code, Images and Meme related to the course Technologies for Advanced Programming

golang lib for kafka

基于Ansible API的任务执行引擎，支持adhoc和playbook两种任务的执行

Workshop Big Data en Español

基于Django2.2开发，支持用户下发adhoc和playbook任务，以及查询任务的执行结果

Geospatial UDFs for KSQL

Choreography-based sagas to maintain data consistency in a microservice architecture.

大数据生态解决方案基础平台: 搜索系统、公共系统、任务管理系统、数据binlog采集、基础爬虫系统、数据传输系统、运维告警系统、APM、报表系统

Catenae 2 – Microservices Framework for Kafka

:cloud: nodejs kafka connect connector for Google BigQuery

Kafka streams microservice on Docker

Kafka docker image, ready for k8s and openshift clusters

MySQL to NoSQL real time dataflow

Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs

A Real-time Apache log monitor using Kafka & Spark Streaming, with fake log generator.

Minikube for big data with Scala and Spark

Enhancing Kafka security, PlainSaslServer with LDAP binding and SimpleAclAuthorizer with LDAP group membership

Python library for Lenses.io / Kafka platform engineers

Kafka De/Serializer using avro and Confluent's Schema Registry

Ansible role to install Apache Kafka

Automated Real-Time Indian Railway Twitter Complaint Administration System. It uses Apache Kafka, Spark, MySQL, PHP. The full project is deployed on A...

A plugin for the Besu enterprise-grade Ethereum client with the aim of making it easier to extract chain data into a variety of different data stores...

Scrapy and Kafka

Kafka Partitions Assignment Optimizer

基于Spring Boot 2.2.x ，后续将不断加入其他框架示例，以期能将这些功能整合起来进行项目的独立开发。后续将持续更新......

Kafka backend for processing device data

容器日志搜集套件。

Enterprise Service Bus - Java

Open Source data and event driven real time Monitoring and Analytics Platform

Spring Cloud Stream Transactional Messaging Extension

Credit card fraud detection using kafka,scikit,flask,cassandra

ART is a kit of modules for developing multifunctional Java applications

a Kafka connector for copying data between Kafka and Elasticsearch, and create the Elasticsearch index daily

Rsyslog server with multiple input listeners (UDP/TCP/RELP) and outputs (file/kafka/syslog).

scaffold是一个基于Yii2高级项目模版工程化实现的应用程序

Apache Kafka / Confluent KSQL REST Client for PHP

Real-time message streaming over a Hazelcast in-memory data grid

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.