130 Open source projects that are alternatives of or similar to php-kafka-lib

Pulsar Flex is a modern Apache Pulsar client for Node.js, developed to be independent of C++.

Kafka library in Go

Confluent's Apache Kafka Golang client

The magic message bus

youtube download queue websocket server with login for private NAS.

RocketMQ client for go supportting producer and consumer.

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

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

Apache Avro is a data serialization system.

Consumer Banking Application

Record Query - A tool for doing record analysis and transformation

A Gradle plugin to allow easily performing Java code generation for Apache Avro. It supports JSON schema declaration files, JSON protocol declaration files, and Avro IDL files.

RabbitMQ Messaging Polyglot with Java, ColdFusion, CommandBox, Groovy and more

Flexible, Fast & Compact Serialization with RPC

Golang Client for Schema Registry

BunnyMQ is an amqp.node wrapper to ease common AMQP usages (RPC, pub/sub, channel/connection handling etc.).

Avro SerDe for Apache Spark structured APIs.

Scala library to eliminate boilerplate

Confluent Schema Registry for Kafka

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

A configurable RabbitMQ consumer made in Rust, useful for a stable and reliable CLI commands processor.

Plugin SBT to Generate Scala classes from Apache Avro schemas hosted on a remote Confluent Schema Registry.

Schema registry for CSV, TSV, JSON, AVRO and Parquet schema. Supports schema inference and GraphQL API.

Kafka backed service library.

A PHP 7.3+ API client for the Confluent Schema Registry REST API based on Guzzle 6 - http://docs.confluent.io/current/schema-registry/docs/index.html

A cross-platform (Windows, MAC, Linux) desktop application to view common bigdata binary format like Parquet, ORC, AVRO, etc. Support local file system, HDFS, AWS S3, Azure Blob Storage ,etc.

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

How to use Parquet in Flink

MongoDB Kafka Connector

Avrow is a pure Rust implementation of the avro specification https://avro.apache.org/docs/current/spec.html with Serde support.

☀️ A tool for validating data using JSON Schema and converting JSON Schema documents into different data-interchange formats

Ruby DSL to create Avro schemas

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Make record oriented data to columnar format.

A fast Go Avro codec

Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala

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

This repository houses the interactions, consultations and work management to support the maintenance of baselined components of the Consumer Data Right API Standards and Information Security profile.

Example MapReduce jobs in Java, Hive, Pig, and Hadoop Streaming that work on Avro data.

Implementing a Web Based solution through which farmers can participate in a commodity exchange market

A CLI and Go client for Kafka Schema Registry

Consume an AWS Kinesis Data Stream to look over the records from a terminal.

Data Preview 🈸 extension for importing 📤 viewing 🔎 slicing 🔪 dicing 🎲 charting 📊 & exporting 📥 large JSON array/config, YAML, Apache Arrow, Avro, Parquet & Excel data files

GCS support for avro-tools, parquet-tools and protobuf

A collection of Magnolia add-on modules

Avro Serialisation/Deserialisation (SerDe) library for PHP 7.3+ & 8.0 with a Symfony Serializer integration

Avro support for kotlinx.serialization

A collection of Apache Parquet add-on modules

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

⛈️ Rumble 1.11.0 "Banyan Tree"🌳 for Apache Spark | Run queries on your large-scale, messy JSON-like data (JSON, text, CSV, Parquet, ROOT, AVRO, SVM...) | No install required (just a jar to download) | Declarative Machine Learning and more

Standalone alternatives to Kafka Connect Connectors

The metrics pipeline for DC/OS 1.9-1.11

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

Demo applications and code examples for Confluent Platform and Apache Kafka

A library provides consumer/producer to work with kafka, avro and schema registry

Services in Ember are scoped to the app as a whole and are singletons. Sometimes you don't want that. :) This addon provides ephemeral route-based services.

Uber-project for standard Jackson binary format backends: avro, cbor, ion, protobuf, smile

Avrocado is a convenience library to handle Avro in Golang

Avro for JavaScript ⚡️

Mu (μ) is a purely functional framework for building micro services.