Awesome Open Source

Programming Languages

Search results for kafka messaging

68 search results found

Jocko ⭐ 4,818

Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)

Ockam ⭐ 4,325

Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications – at massive scale.

Strimzi Kafka Operator ⭐ 4,228

Apache Kafka® running on Kubernetes

Liftbridge ⭐ 2,413

Lightweight, fault-tolerant message streams.

Metamorphosis ⭐ 1,261

A high available,high performance distributed messaging system.

Alpakka ⭐ 1,259

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Mirror of Apache Samza

Fast and reliable message broker built on top of Kafka.

a fast and simple distributed publish-subscribe messaging system (mq)

Parallel Consumer ⭐ 605

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

Propan is a powerful and easy-to-use Python framework for building event-driven applications that interact with any MQ Broker

Slimmessagebus ⭐ 412

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

Automq For Kafka ⭐ 304

A cloud native implementation for Apache Kafka, reducing your cloud infrastructure bill by up to 90%.

Go Random Chat ⭐ 293

Modern real-time chat in scalable architecture.

Joyqueue ⭐ 266

A cloud-native production-quality messaging platform with high performance

Silverback ⭐ 234

Silverback is a simple but feature-rich message bus for .NET core (it currently supports Kafka, RabbitMQ and MQTT).

Smallrye Reactive Messaging ⭐ 218

SmallRye Reactive Messaging

Laravel Queue ⭐ 216

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

Azure Event Hubs For Kafka ⭐ 191

Azure Event Hubs for Apache Kafka Ecosystems

A high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC

Openchaos ⭐ 137

Chaos Framework proposes a unified API for vendors to provide solutions to various aspects of performing the principles of chaos engineering in cloud-native environment.

Li Apache Kafka Clients ⭐ 125

li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients. It provides additional features such as large message support and auditing to the Java producer and consumer in the open source Apache Kafka.

Module Ballerinax Kafka ⭐ 119

Ballerina Kafka Module.

A full ecosystem that is built around kafka powered by golang

Automq For Rocketmq ⭐ 86

A cloud native implementation for Apache RocketMQ 5.0

Micronaut Kafka ⭐ 80

Integration between Micronaut and Apache Kafka

Strimzi Kafka Cli ⭐ 69

Command Line Interface for the Strimzi Kafka Operator

Extension Kafka ⭐ 63

Axon Framework extension for Kafka integration to publish and handle Event messages.

Pact Example ⭐ 55

Example project to demonstrate Contract Testing via Pact.

Awesome Pulsar ⭐ 53

A curated list of Pulsar tools, integrations and resources.

Kafkaflow Retry Extensions ⭐ 50

Kafka Flow Retry Patterns Extensions

Javaroadstorm2016 ⭐ 44

Microservice_workshop ⭐ 43

Microservices Architecture Workshop focuses on helping the developers / architects to understand the key Architecture paradigms with hands on section. The course helps the developers from Monolithic App mindset to a Microservices based App development. It also helps the developers with hands on development experience with key Microservices infrastructure technologies like Eureka, Ribbon, Zuul, Kafka etc., and key Architecture styles likes Domain Driven Design, Event Sourcing and CQRS, Functional

Drinking From The Stream ⭐ 38

Spring Cloud Stream Java projects to accompany my session titled Drinking from the Stream

Magento2 Enqueue ⭐ 37

The extension adds messaging capabilities to Magento2 application.

Amq Examples ⭐ 37

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

Spring Cloud Stream Demo ⭐ 35

Simple Event Driven Microservices with Spring Cloud Stream

Eventuate Tram Core Examples Basic ⭐ 34

Basic examples for Eventuate Tram

Streamsx.messaging ⭐ 30

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

Strimzi Canary ⭐ 29

Building Data Streaming Applications With Apache Kafka ⭐ 27

Building Data Streaming Applications with Apache Kafka, published by Packt

Py Avro Schema ⭐ 24

Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.

Memphis K8s ⭐ 22

Memphis.dev is an intelligent, frictionless message broker. Made to enable developers to build real-time and streaming features fast.

Camel Kafka ⭐ 22

Apache Camel, Kafka Component

yet another databus that transfer/transform pipeline data between plugins

Spring Cloud Stream Outbox Extension ⭐ 18

Spring Cloud Stream Transactional Messaging Extension

Sample Kafka Micronaut Microservices ⭐ 17

Sample microservices written using Micronaut framework communicating asynchronously through Apache Kafka

Web hooks for message queues

Streamsx.kafka ⭐ 13

Repository for integration with Apache Kafka

Microprofile Reactive Messaging ⭐ 13

Lightbend's implementation of the MicroProfile Reactive Messaging spec

Localmessaging ⭐ 13

Scripts I use to create Docker images, create config, & run containers for RabbitMQ and Zookeeper+Kafka. Nothing fancy, they just work. :)

Tibco Messaging ⭐ 12

TIBCO Messaging

Quarkus Reactive Messaging Demo ⭐ 11

Eigenflow ⭐ 9

ETL orchestration platform with recoverability and process monitoring features

Amqp Kafka Demo ⭐ 9

Bridging AMQP - Kafka demo

Laravel Kafka Pub Example ⭐ 8

Pub-Sub Messaging with Laravel and Apache Kafka Example (Publisher)

Trackrdrd ⭐ 8

The Tracking Log Reader demon reads from the shared memory log of a running instance of Varnish, aggregates data logged in a specific format for requests and ESI subrequests, and forwards the data to a messaging system (such as ActiveMQ or Kafka).

Dafka Consumer ⭐ 8

Dockerized Kafka consumer

Enmasse Iot Demo ⭐ 7

EnMasse - IoT demo

Messaging ⭐ 7

Library for simple pub/sub with different serialization and brokers

Serilog Sinks Kafka ⭐ 7

Write structured logging events to a Kafka topic using Serilog in .NET

Apache Pulsar Demo ⭐ 6

Apache Pulsar demo

Workshop Quarkus Openshift Reactive Messaging ⭐ 6

Workshop: Reactive Messaging with Quarkus on OpenShift

Simple messaging client for the shell (JMS, AMQP, Kafka)

Pubsubplus Connector Kafka Sink ⭐ 6

Sink connector to recieve data from Apache Kafka streaming platform and send to Solace message broker

Kafka Hybrid Iot ⭐ 6

Apache Kafka for the Hybrid IoT

Messaging Adapter ⭐ 5

Messaging adapter gem for Ruby, useful for using message brokers (RabbitMQ, Kafka,...) in Ruby applications

Bringing Reactive To Enterprise Java ⭐ 5

Demo code for the "bringing reactive to Java enterprise application talk"

Related Searches

Java Kafka (3,367)

Kafka Zookeeper (1,229)

Javascript Messaging (1,183)

Docker Kafka (1,182)

Python Kafka (1,133)

Java Messaging (1,008)

Spark Kafka (979)

Scala Kafka (969)

Golang Kafka (919)

Apache Kafka (838)

1-68 of 68 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.