A lightweight stream processing library for Go

Apache Pulsar Go Client Library

kratos transport layer extension

a CLI for Apache Pulsar written in Go

A Go client library for Apache Pulsar

Pulsar Operator creates/configures/manages pulsar clusters atop Kubernetes

Elastic Beats Output to Apache Pulsar

Data exfiltration and covert communication tool

Pulsar Heartbeat monitors Pulsar cluster availability, tracks latency of Pulsar message pubsub, and reports failures of the Pulsar cluster. It produces synthetic workloads to measure end-to-end message pubsub latency.

go broker interface,you can use kafka,redis,pulsar etc.

Apache Pulsar Golang Client Library

Pulsar Monitor monitors the availability, tracks the performance, and reports failures of the Pulsar cluster. It produces synthetic workloads to measure end-to-end message pubsub latency. It is a cloud native application that can be installed by Helm within the Pulsar Kubernetes cluster.

Command line utilities for working with Pulsar Route Maps

A proxy to Pulsar cluster

Argo Events Sensor POC

Protocol Buffer schema and example code for Bulk Data Ingestion with Pulsar.

Kafka, Beanstalkd, Pulsar Pub/Sub framework. Reference: https://github.com/zeromicro/go-queue

盘古框架Pulsar MQ系统集成，提供更友好的API接口，同时支持如下功能：1、易于接入；2、提供多种序列化和反序列化（包括：Protobuf、JSON、XML以及Msgpack）；3、多集群接入

Simple demo project.

Golang client library for Yahoo!'s Pulsar