g41797/queue-pulsar

Yii3 Queue Adapter for Apache Pulsar

Language: PHP - Size: 17.9 MB - Last synced: about 10 hours ago - Pushed: about 11 hours ago - Stars: 0 - Forks: 0

FunctionStream/function-stream

Function Stream - Event-streaming function platform based on Apache Pulsar and WebAssembly

Language: Go - Size: 1.06 MB - Last synced: about 13 hours ago - Pushed: 1 day ago - Stars: 34 - Forks: 15

streamnative/pulsar-io-activemq

ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.

Language: Java - Size: 85 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 6 - Forks: 5

streamnative/aop

AMQP on Pulsar protocol handler

Language: Java - Size: 1.5 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 110 - Forks: 46

streamnative/mop

MQTT on Pulsar implemented using Pulsar Protocol Handler

Language: Java - Size: 2.77 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 163 - Forks: 51

tealtools/awesome-apache-pulsar

A curated list of resources about Apache Pulsar.

Size: 367 KB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 24 - Forks: 1

streamnative/function-mesh

The serverless framework purpose-built for event streaming applications.

Language: Go - Size: 27.9 MB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 209 - Forks: 27

apache/pulsar-manager

Apache Pulsar Manager

Language: Vue - Size: 12.3 MB - Last synced: 10 days ago - Pushed: 20 days ago - Stars: 508 - Forks: 242

apache/pulsar-client-reactive

Reactive client for Apache Pulsar

Language: Java - Size: 595 KB - Last synced: 10 days ago - Pushed: 14 days ago - Stars: 55 - Forks: 16

streamnative/pulsar-hub

The canonical source of StreamNative Hub.

Language: JavaScript - Size: 12.4 MB - Last synced: 11 days ago - Pushed: 12 days ago - Stars: 18 - Forks: 11

profunktor/neutron

:stars: Purely functional Apache Pulsar client for Scala built on top of Fs2

Language: Scala - Size: 1.44 MB - Last synced: 13 days ago - Pushed: 13 days ago - Stars: 15 - Forks: 4

Sharp-Pulsar/SharpPulsar

SharpPulsar is an Apache Pulsar Client built on top Akka.NET!

Language: C# - Size: 22.3 MB - Last synced: 15 days ago - Pushed: 27 days ago - Stars: 56 - Forks: 4

streamnative/homebrew-streamnative

StreamNative Homebrew Formulae

Language: Ruby - Size: 52.7 KB - Last synced: 16 days ago - Pushed: 16 days ago - Stars: 5 - Forks: 3

datastax/pulsar-transformations

Language: Java - Size: 39.5 MB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 9 - Forks: 8

datastax/snowflake-connector

Datastax Snowflake Sink Connector for Apache Pulsar

Language: Java - Size: 154 KB - Last synced: 22 days ago - Pushed: about 1 year ago - Stars: 8 - Forks: 4

datastax/kaap

KAAP, Kubernetes Autoscaling for Apache Pulsar

Language: Java - Size: 3.53 MB - Last synced: 22 days ago - Pushed: 24 days ago - Stars: 37 - Forks: 11

datastax/starlight-for-rabbitmq

Starlight for RabbitMQ, a proxy layer between RabbitMQ/AMQP0.9.1 clients and Apache Pulsar

Language: Java - Size: 490 KB - Last synced: 22 days ago - Pushed: almost 1 year ago - Stars: 28 - Forks: 11

streamnative/private-cloud

StreamNative Private Cloud is an enterprise product which brings specific controllers for Kubernetes by providing specific Custom Resource Definitions (CRDs).

Language: Shell - Size: 153 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 4 - Forks: 2

alexandrebrilhante/tick_handler

Low-latency market data feed handler.

Language: Rust - Size: 19.1 MB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 1 - Forks: 0

gvolpe/trading

💱 Trading application written in Scala 3 that showcases an Event-Driven Architecture (EDA) and Functional Programming (FP)

Language: Scala - Size: 23.5 MB - Last synced: 27 days ago - Pushed: 27 days ago - Stars: 603 - Forks: 65

leobenkel/local-docker-pulsar

Example to run Pulsar locally using docker compose

Language: Python - Size: 1.95 KB - Last synced: 30 days ago - Pushed: almost 4 years ago - Stars: 0 - Forks: 0

anthonycorletti/fullstack-kubernetes

Deploy a fullstack app on kubernetes anywhere, UI to Secrets.

Language: Shell - Size: 222 KB - Last synced: 30 days ago - Pushed: almost 4 years ago - Stars: 1 - Forks: 0

streamnative/terraform-provider-pulsar

Terraform provider for managing Apache Pulsar entities

Language: Go - Size: 526 KB - Last synced: 29 days ago - Pushed: about 1 month ago - Stars: 39 - Forks: 36

tealtools/puls

The simplest way to run a local multi-cluster multi-broker Apache Pulsar instance 🚀

Language: Rust - Size: 145 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 2 - Forks: 0

streamnative/apache-pulsar-grafana-dashboard

Apache Pulsar Grafana Dashboard

Language: Jinja - Size: 561 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 87 - Forks: 94

97arushisharma/Apache_Pulsar

This repository contains the sample apache pulsar producer and consumer with various properties enabled.

Language: Java - Size: 24.4 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

mattisonchao/mini-pulsar

This project uses the web to demonstrate how pulsar works.

Size: 4.88 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 1 - Forks: 0

arkady-emelyanov/pulsar-playground

Apache Pulsar playground

Language: Go - Size: 7.81 KB - Last synced: about 1 month ago - Pushed: almost 3 years ago - Stars: 0 - Forks: 0

streamnative/pulsar-beat-output

Elastic Beats Output to Apache Pulsar

Language: Go - Size: 193 MB - Last synced: about 1 month ago - Pushed: 11 months ago - Stars: 54 - Forks: 22

yjshen/spark-connector-test

A tutorial on how to use pulsar-spark-connector

Language: Scala - Size: 12.7 KB - Last synced: about 2 months ago - Pushed: over 3 years ago - Stars: 10 - Forks: 3

cr-org/supernova

:milky_way: Apache Pulsar client for Haskell

Language: Haskell - Size: 293 KB - Last synced: 9 days ago - Pushed: over 3 years ago - Stars: 38 - Forks: 5

degisew/security_alert

Secure Alert is a web application designed to enhance the security of user accounts by providing real-time monitoring of login activities, detecting unusual login patterns, tracking device information, and notifying users through security alert emails, similar to Gmail's security alerts.

Language: Python - Size: 85.9 KB - Last synced: about 2 months ago - Pushed: 5 months ago - Stars: 1 - Forks: 0

lhotari/reactive-iot-backend-ApacheCon2021

source code of the live coding demo for "Building resilient and scalable API backends with Apache Pulsar and Spring Reactive" talk held at ApacheCon@Home 2021

Language: Java - Size: 562 KB - Last synced: about 2 months ago - Pushed: 5 months ago - Stars: 4 - Forks: 2

lhotari/pulsar-spring-cloud-stream-binder

Apache Pulsar binder for Spring Cloud Stream

Language: Java - Size: 33.2 KB - Last synced: about 2 months ago - Pushed: about 2 years ago - Stars: 13 - Forks: 6

streamnative/charts

StreamNative Helm Charts Repository: Apache Pulsar, Pulsar Operators, StreamNative Platform, Function Mesh

Language: Smarty - Size: 4.02 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 82 - Forks: 72

streamnative/pulsarctl

a CLI for Apache Pulsar written in Go

Language: Go - Size: 5.66 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 144 - Forks: 64

streamnative/kop 📦

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Language: Java - Size: 7.44 MB - Last synced: about 2 months ago - Pushed: 4 months ago - Stars: 445 - Forks: 126

streamnative/pulsar-spark

Spark Connector to read and write with Pulsar

Language: Scala - Size: 697 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 109 - Forks: 48

emc-mongoose/mongoose-storage-driver-pulsar

Apache Pulsar extension for Mongoose

Language: Java - Size: 108 KB - Last synced: 2 months ago - Pushed: about 1 year ago - Stars: 3 - Forks: 2

tealtools/dekaf

Dekaf is a visual user interface for Apache Pulsar 🛸

Size: 51.8 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 3 - Forks: 0

bitspire/pulsar-meetup

Demos used in Pulsar meetup on October 24th, 2022 at Toronto

Language: Java - Size: 114 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 8 - Forks: 1

tomjo/pulsar-bookie-utils

A command-line utility to perform various maintenance tasks for Apache Pulsar / BookKeeper.

Language: Java - Size: 155 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

codingforentrepreneurs/getting-started-with-pulsar

Learn the basics of streaming data with Apache Pulsar. Apache Pulsar is a cloud-native, distributed messaging and streaming platform.

Language: Python - Size: 5.86 KB - Last synced: 3 months ago - Pushed: about 2 years ago - Stars: 4 - Forks: 1

aahmed-se/pulsar-io-gradle

Pulsar IO Gradle template

Language: Java - Size: 59.6 KB - Last synced: 3 months ago - Pushed: over 4 years ago - Stars: 1 - Forks: 0

CORDEA/Vulpecula

Apache Pulsar Playground

Language: F# - Size: 12.7 KB - Last synced: 3 months ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

kuangye098/Pulsar-analysis

Apache Pulsar Source code analysis

Size: 684 KB - Last synced: 3 months ago - Pushed: over 4 years ago - Stars: 137 - Forks: 46

streamnative/pulsar-flink 📦

Elastic data processing with Apache Pulsar and Apache Flink

Language: Java - Size: 2.16 MB - Last synced: 3 months ago - Pushed: over 1 year ago - Stars: 280 - Forks: 118

streamnative/examples

Apache Pulsar examples and demos

Language: Java - Size: 401 KB - Last synced: 4 months ago - Pushed: 12 months ago - Stars: 51 - Forks: 31

datastax/reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

Language: Java - Size: 268 KB - Last synced: 22 days ago - Pushed: about 1 year ago - Stars: 47 - Forks: 15

datastax/pulsar-3rdparty-connector

This project provides simple templates and instructions to build Apache Pulsar connectors on base of the existing Apache Kafka connectors.

Language: Shell - Size: 466 KB - Last synced: 22 days ago - Pushed: about 1 year ago - Stars: 8 - Forks: 10

lhotari/reactive-pulsar-showcase

SpringBoot show case application for pulsar-client-reactive library (Reactive Client for Apache Pulsar)

Language: Java - Size: 213 KB - Last synced: about 2 months ago - Pushed: 6 months ago - Stars: 11 - Forks: 5

ckam99/fastapi

FastAPI ecommerce,Micro framework based on FastAPI,FastAPI ORMS,FastAPI Sqlalchemy ORM, FastAPI Tortoise ORM Relationship,FastAPI Websocket,Event Stream in Djando and FastAPI using Rabbitmq, Event Sourcing with Apache Kafka microservices, Event Stream with Apache Kafka microservices, Event Stream with Apache Pulsar

Size: 27.6 MB - Last synced: 6 months ago - Pushed: about 2 years ago - Stars: 18 - Forks: 4

kafkaesque-io/pulsar-helm-chart

Helm Chart for an Apache Pulsar Cluster

Language: Mustache - Size: 2.17 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 31 - Forks: 23

blueshift-labs/neutron

Apache Pulsar client based on C nifs

Language: C - Size: 104 KB - Last synced: 24 days ago - Pushed: 4 months ago - Stars: 3 - Forks: 2

ajorlosky/Apache-Pulsar-Development

In this project, I have included several files that enable a user to ingest StockTicker data from a Producer as messages into a Pulsar instance (Standalone, Multi-node cluster, and Multiple Clsuters). In addition, there are a variety of Consumer subscription types that enable different subscription types available in Apache Pulsar by simply running the subscription of choice in the consumers package. The generated payload data is formatted with JSON Schema for the StockTicker object, so that the key is a ticker symbol and message includes current stock information. Using this data streaming model, it should provide us with data to ingest into our own Pulsar instance, which can then be used to modify our Pulsar instance for potential customer needs.

Language: Jupyter Notebook - Size: 76.7 MB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 1 - Forks: 0

Redislabs-Solution-Architects/redis-pulsar

Redis + Apache Pulsar integration

Language: Java - Size: 5.68 MB - Last synced: about 2 months ago - Pushed: about 1 year ago - Stars: 1 - Forks: 0

dev5c32373043/analytika

Basic Analytics Service

Language: TypeScript - Size: 355 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

streamnative/sn-platform

StreamNative Platform Downloads

Size: 113 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 12 - Forks: 4

krvarma/pulsar-ext-scaler-for-keda

Apache Pulsar External Scaler for KEDA

Language: Go - Size: 2.84 MB - Last synced: 10 months ago - Pushed: almost 4 years ago - Stars: 5 - Forks: 4

kafkaesque-io/pulsar-beam

Pulsar Beam is a streaming service via HTTP built on Apache Pulsar.

Language: Go - Size: 315 KB - Last synced: 10 months ago - Pushed: almost 2 years ago - Stars: 56 - Forks: 14

streamnative/pulsar-recipes

A StreamNative library containing a collection of recipes that are implemented on top of the Pulsar client to provide higher-level functionality closer to the application domain.

Language: Java - Size: 80.1 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 8 - Forks: 7

develop-for-apache-pulsar/vscode-extension

A Visual Studio Code extension to work with different types of Apache Pulsar clusters

Language: TypeScript - Size: 986 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 1 - Forks: 0

jczuchnowski/zio-pulsar

Apache Pulsar client for Scala with ZIO and ZIO Streams integration.

Language: Scala - Size: 179 KB - Last synced: 11 months ago - Pushed: 11 months ago - Stars: 21 - Forks: 5

streamnative/tgip-cn

TGIP-CN (Thank God Its Pulsar) is a weekly live video streaming about Apache Pulsar in Chinese.

Size: 162 MB - Last synced: 7 months ago - Pushed: almost 3 years ago - Stars: 102 - Forks: 24

jbvanzuylen/cf-pulsar-gateway

Apache Pulsar Gateways for ColdFusion

Language: Java - Size: 36.1 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 4 - Forks: 3

streamnative/awesome-pulsar

A curated list of Pulsar tools, integrations and resources.

Size: 11.7 KB - Last synced: 11 days ago - Pushed: over 3 years ago - Stars: 78 - Forks: 9

yjshen/pulsar-internals

Apache Pulsar 源码解析

Size: 1.95 KB - Last synced: about 2 months ago - Pushed: over 4 years ago - Stars: 3 - Forks: 2

streamnative/pulsar-io-kafka 📦

Pulsar IO Kafka Connector

Language: Java - Size: 200 KB - Last synced: 2 months ago - Pushed: about 1 year ago - Stars: 24 - Forks: 12

monolito-solutions/project

Monolito Solutions Project

Size: 80.1 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

monolito-solutions/notifications-ui

Order notifications UI

Language: HTML - Size: 453 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 1 - Forks: 0

MISW4406/tutorial-7-event-sourcing

Repositorio con código base con la implementación de un servicio usando el patrón Event Sourcing

Language: Python - Size: 89.6 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 1 - Forks: 14

streamnative/pulsar-tracing

Tracing instrumentation for Apache Pulsar clients.

Language: Java - Size: 33.2 KB - Last synced: 4 months ago - Pushed: about 1 year ago - Stars: 20 - Forks: 10

streamnative/tgip

TGIP (TGI Pulsar) is a weekly live video streaming about Apache Pulsar and its ecosystem.

Language: Shell - Size: 69.7 MB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 18 - Forks: 7

MISW4406/tutorial-5-cqrs-eventos

Repositorio con código base para el uso de un sistema usando el patrón CQRS y usando eventos de dominio e integración para la comunicación asíncrona entre componentes internos parte del mismo contexto acotado y sistemas externos.

Language: Python - Size: 5.91 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 12

morsapaes/flink-sql-pulsar 📦

Self-contained demo using Flink SQL and Apache Pulsar to build a simple analytics pipeline. All you need is Docker! 🐳

Language: Dockerfile - Size: 15.6 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 5 - Forks: 6

solimy/pulsar-testing 📦

just trying out pulsar

Language: Python - Size: 4.88 KB - Last synced: over 1 year ago - Pushed: almost 5 years ago - Stars: 0 - Forks: 0

MISW4406/tutorial-6-cdc

Repositorio con código base para la liberación de datos por medio de eventos con carga de estados usando un mecanismo de lectura de logs.

Language: Python - Size: 89.6 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 5

flipkart-incubator/pulsar-weighted-consumer

Pulsar consumer clients offering priority consumption

Language: Java - Size: 396 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 9 - Forks: 4

archfish/pulsar_sdk

A pure ruby client for Apache Pulsar

Language: Ruby - Size: 175 KB - Last synced: 26 days ago - Pushed: about 4 years ago - Stars: 12 - Forks: 4

streamthoughts/apache-pulsar-cheat-sheet

This cheat sheet is filled with some handy tips, commands and code snippets to get you streaming data using Apache Pulsar in no time!

Language: Java - Size: 56.6 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 26 - Forks: 7

anicetkeric/spring-apache-pulsar

https://boottechnologies-ci.medium.com/apache-pulsar-consumer-and-producer-with-spring-boot-916fd06f669

Language: Java - Size: 68.4 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 2 - Forks: 4

jmoussa/pulsar-http-client

A FastAPI Pulsar HTTP client.

Language: Python - Size: 29.3 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 3 - Forks: 1

pascaldevink/awesome-pulsar

A curated list of Apache Pulsar resources

Size: 10.7 KB - Last synced: 9 days ago - Pushed: over 5 years ago - Stars: 13 - Forks: 3

streamnative-oss/sn-pulsar-rs Fork of streamnative/pulsar-rs

Rust Client library for Apache Pulsar

Language: Rust - Size: 655 KB - Last synced: about 1 year ago - Pushed: about 2 years ago - Stars: 15 - Forks: 5

streamthoughts/pulsar-quickstart-java

This project demonstrates how to write simple producers and consumers for Apache Pulsar

Language: Java - Size: 7.81 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 3 - Forks: 2

ypt/experiment-flink-cdc-connectors-postgres-datastream

An experiment with Flink's Debezium based flink-cdc-connectors DataStream API and Pulsar's Flink connector

Language: Java - Size: 85 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 5 - Forks: 3

memgraph/ecommerce-recommender-demo

E-Commerce recommender demo with real-time data and a graph database

Language: Python - Size: 25.4 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 3 - Forks: 0

streamnative/pulsar-flume-ng-sink

An Apache Flume Sink implementation to publish data to Apache pulsar

Language: Java - Size: 33.2 KB - Last synced: 3 months ago - Pushed: over 1 year ago - Stars: 19 - Forks: 14

116davinder/apache-pulsar-ansible

Fully Managed Apache Pulsar with Ansible.

Language: HCL - Size: 4.97 MB - Last synced: over 1 year ago - Pushed: almost 4 years ago - Stars: 9 - Forks: 5

cbornet/generator-jhipster-pulsar

JHipster module to support Apache Pulsar in your JHipster app

Language: HTML - Size: 548 KB - Last synced: 28 days ago - Pushed: over 1 year ago - Stars: 3 - Forks: 2

streamnative/community

StreamNative / Apache Pulsar ecosystem community

Size: 242 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 5 - Forks: 3

CleverCloud/nodejs-pulsar-example

This repository demonstrates the usage of Apache Pulsar with a dead simple Node.js application.

Language: JavaScript - Size: 55.7 KB - Last synced: about 2 months ago - Pushed: over 2 years ago - Stars: 2 - Forks: 2

xujakai/pulsar-ansible

使用ansible快速搭建apache pulsar集群

Size: 14.6 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 1 - Forks: 2

prabal77/ApachePulsarConnecitivityPlugin

Apama Connectivity Plugin for Apache Pulsar Messaging Framework.

Language: Java - Size: 30.1 MB - Last synced: over 1 year ago - Pushed: over 5 years ago - Stars: 1 - Forks: 0

quiye/pulsar-rust-websocket-client

Rust websocket producer sample codes for Apache Pulsar

Language: Rust - Size: 5.86 KB - Last synced: about 2 months ago - Pushed: over 5 years ago - Stars: 2 - Forks: 2

kafkaesque-io/fluent-plugin-pulsar

Fluentd Apache Pulsar output plugin

Language: Ruby - Size: 6.84 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 4 - Forks: 1

Rahonam/apache-pulsar-python

apache pulsar python implementation

Language: Python - Size: 0 Bytes - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

p-zalejko/reactive-messaging-pulsar

Language: Java - Size: 43.9 KB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0

kafkaesque-io/pulsar-client-plugin

Pulsar client plugin for auth0, aws cognito, and etc.

Language: Java - Size: 42 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 2