Nakadi - A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

  •        72

Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues. It provides abstract event delivery via a secured RESTful API, Enable convenient development of event-driven applications and asynchronous microservices, Efficient low latency event delivery.

https://zalando.github.io/nakadi/
https://github.com/zalando/nakadi

Tags
Implementation
License
Platform

   




Related Projects

raet - Reliable Asynchronous Event Transport Protocol


Modern large scale distributed application architectures, wherein components are distributed across the internet on multiple hosts and multiple CPU cores, are often based on a messaging or event bus that allows the various distributed components to communicate asynchronously with each other. Typically the messaging bus is some form of messaging queue service such as AMQP or ZeroMQ. The message bus supports what is commonly referred to as a publish/subscribe methodology for information exchange.While there are many advantages to a full featured message queuing service, one of the disadvantages is the inability to manage performance at scale.

restful-api-guidelines - A model set of guidelines for RESTful APIs, created by Zalando


Great RESTful APIs look like they were designed by a single team. This promotes API adoption, reduces friction, and enables clients to use them properly. To build APIs that meet this standard, and to answer many common questions encountered along the way of RESTful API development, the Zalando Tech team has created this comprehensive set of guidelines. We have shared it with you to inspire additional discussion and refinement within and among your teams, and contribute our learnings and suggestions to the tech community at large.Feel free to use these guidelines as a guidance for your own development. Note that we encourage our own teams to use them in order to challenge their APIs. As such, you should consider this to be a living, evolving document. We will revise and update based on our learnings and experiences.

MBassador - Light-weight, high-performance event bus implementing the publish subscribe pattern


MBassador is a light-weight, high-performance event bus implementing the publish subscribe pattern. It is designed for ease of use and aims to be feature rich and extensible while preserving resource efficiency and performance. The core of MBassador is built around a custom data structure that provides non-blocking reads and minimized lock contention for writes such that performance degradation of concurrent read/write access is minimal.



hermes - Fast and reliable message broker built on top of Kafka.


Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and adaptive push mechanisms for message sending.Questions? We are on gitter.

Microsoft-Message-Bridge - A messaging bridge that transforms messages and connects different real time interfaces such as service bus and event hub


A messaging bridge that transforms messages and connects different real time interfaces such as service bus and event hub. Common uses may be cleaning or transforming incoming JSON data before pushing down stream to another hub, bus or webapi We have used Microsoft Message Bridge to connect streams to signalR sites to drive data visualization experiences. In other cases we have used Microsoft Message Bridge as a point to intercept the stream and cache a subset of entities and attributes in Redis.

nsq-event-bus - A tiny wrapper around NSQ topic and channel :rocket:


The nsq-event-bus package exposes a interface for emitting and listening events.

pykafka - Python API for the Kafka Message Queue


pykafka allows you to produce messages to the Kafka distributed publish/subscribe messaging service.

RocketMQ - Distributed messaging and streaming data platform


Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.

eventsourcing-example - Example of an eventsourcing microservices application with Kafka running on Kontena


This repository is an example of a microservices style application using the event sourcing pattern, with Kafka as both the event publishing mechanism and the events source of truth. It contains a mixture of C# (.Net Core 2.0), Ruby and TypeScript.Kafka and Zookeeper are installed as Kontena Stacks, and are based on fantastic work done by the Harvard Center for Geographic Analysis (CGA) for their hhypermap-bop project.

dbus - Native Go bindings for D-Bus


dbus is a simple library that implements native Go client bindings for the D-Bus message bus system.If you want to use the subpackages, you can install them the same way.

cnats - A C client for NATS


A C client for the NATS messaging system.Go here for the online documentation.

li-apache-kafka-clients - li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients


li-apache-kafka-clients is a wrapper Kafka clients library built on top of vanilla Apache Kafka clients.Apache Kafka has now become a very popular messaging system and is well known for its low latency, high throughput and durable messaging. At LinkedIn, we have built an ecosystem around Kafka to power our infrastructure. In our ecosystem, li-apache-kafka-clients library is a fundamental component for many functions such as auditing, data format standardization, large message handling, and so on.

RESTful-Message-Bus - RESTful Message Bus for communication between AWS servers and TUI resources


RESTful Message Bus for communication between AWS servers and TUI resources

Vert.x - Tool-kit for building reactive applications on the JVM


Vert.x is a tool-kit for building reactive applications on the JVM. Vert.x is event driven and non blocking. This means your app can handle a lot of concurrency using a small number of kernel threads. Vert.x lets your app scale with minimal hardware.Vert.x is incredibly flexible - whether it's simple network utilities, sophisticated modern web applications, HTTP/REST microservices, high volume event processing or a full blown back-end message-bus application.

ZeroMQ - Messaging Library


The 0MQ lightweight messaging kernel is a library which extends the standard socket interfaces with features traditionally provided by specialised messaging middleware products. 0MQ sockets provide an abstraction of asynchronous message queues, multiple messaging patterns, message filtering (subscriptions), seamless access to multiple transport protocols and more.

benthos - A persisted message bridge between protocols


Benthos is a messaging bridge service that supports a wide and growing list of input and output protocols, helping you to connect pipeline components across diverse platforms with ease.A range of internal buffer strategies are available, allowing you to select a balance between latency, protection against back pressure and file based persistence, or nothing at all (direct bridge).

ruby-kafka - A Ruby client library for Apache Kafka


A Ruby client library for Apache Kafka, a distributed log and message bus. The focus of this library will be operational simplicity, with good logging and metrics that can make debugging issues easier.Although parts of this library work with Kafka 0.8 – specifically, the Producer API – it's being tested and developed against Kafka 0.9. The Consumer API is Kafka 0.9+ only.

RabbitMQ - Robust messaging for applications


RabbitMQ is a messaging broker - an intermediary for messaging. It gives your applications a common platform to send and receive messages, and your messages a safe place to live until received. It features include reliability, high availability, Clustering and Federation. RabbitMQ ships with an easy-to use management UI that allows you to monitor and control every aspect of your message broker. There are RabbitMQ clients for almost any language you can think of.