apache-pulsar | Topic | Ecosyste.ms: Repos

Topic: "apache-pulsar"

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 at: 2 days ago - Pushed at: 4 days ago - Stars: 640 - Forks: 74

apache/pulsar-manager

Apache Pulsar Manager

Language: Vue - Size: 12.3 MB - Last synced at: 4 days ago - Pushed at: 5 months ago - Stars: 533 - Forks: 246

streamnative/kop 📦

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

Language: Java - Size: 7.44 MB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 452 - Forks: 140

streamnative/pulsar-flink 📦

Elastic data processing with Apache Pulsar and Apache Flink

Language: Java - Size: 2.16 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 279 - Forks: 120

streamnative/function-mesh

The serverless framework purpose-built for event streaming applications.

Language: Go - Size: 55.8 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 216 - Forks: 28

streamnative/mop

MQTT on Pulsar implemented using Pulsar Protocol Handler

Language: Java - Size: 4.01 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 179 - Forks: 53

streamnative/pulsarctl

a CLI for Apache Pulsar written in Go

Language: Go - Size: 5.84 MB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 161 - Forks: 68

kuangye098/Pulsar-analysis

Apache Pulsar Source code analysis

Size: 684 KB - Last synced at: about 1 month ago - Pushed at: over 5 years ago - Stars: 144 - Forks: 48

streamnative/aop

AMQP on Pulsar protocol handler

Language: Java - Size: 1.84 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 115 - Forks: 46

streamnative/pulsar-spark

Spark Connector to read and write with Pulsar

Language: Scala - Size: 703 KB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 113 - Forks: 51

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 at: 3 months ago - Pushed at: about 4 years ago - Stars: 105 - Forks: 24

streamnative/apache-pulsar-grafana-dashboard

Apache Pulsar Grafana Dashboard

Language: Jinja - Size: 571 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 91 - Forks: 95

streamnative/charts

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

Language: Smarty - Size: 4.45 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 81 - Forks: 71

streamnative/awesome-pulsar

A curated list of Pulsar tools, integrations and resources.

Size: 11.7 KB - Last synced at: about 2 months ago - Pushed at: over 4 years ago - Stars: 81 - Forks: 9

apache/pulsar-client-reactive

Reactive client for Apache Pulsar

Language: Java - Size: 614 KB - Last synced at: 3 days ago - Pushed at: 12 days ago - Stars: 62 - Forks: 20

Sharp-Pulsar/SharpPulsar

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

Language: C# - Size: 22.5 MB - Last synced at: 15 days ago - Pushed at: 9 months ago - Stars: 60 - 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 at: 7 months ago - Pushed at: almost 3 years ago - Stars: 58 - Forks: 14

streamnative/pulsar-beat-output

Elastic Beats Output to Apache Pulsar

Language: Go - Size: 192 MB - Last synced at: 3 months ago - Pushed at: 9 months ago - Stars: 57 - Forks: 24

streamnative/examples

Apache Pulsar examples and demos

Language: Go - Size: 628 KB - Last synced at: 24 days ago - Pushed at: 2 months ago - Stars: 56 - Forks: 33

FunctionStream/function-stream

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

Language: Go - Size: 1.31 MB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 48 - Forks: 17

datastax/kaap

KAAP, Kubernetes Autoscaling for Apache Pulsar

Language: Java - Size: 3.53 MB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 48 - Forks: 18

datastax/reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

Language: Java - Size: 268 KB - Last synced at: about 2 months ago - Pushed at: about 2 years ago - Stars: 48 - Forks: 15

streamnative/terraform-provider-pulsar

Terraform provider for managing Apache Pulsar entities

Language: Go - Size: 681 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 44 - Forks: 36

cr-org/supernova

:milky_way: Apache Pulsar client for Haskell

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

kafkaesque-io/pulsar-helm-chart

Helm Chart for an Apache Pulsar Cluster

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

tealtools/awesome-apache-pulsar

A curated list of resources about Apache Pulsar.

Size: 367 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 30 - Forks: 3

datastax/starlight-for-rabbitmq

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

Language: Java - Size: 539 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 29 - Forks: 8

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 at: 2 months ago - Pushed at: over 3 years ago - Stars: 28 - Forks: 5

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 at: over 2 years ago - Pushed at: over 4 years ago - Stars: 26 - Forks: 7

streamnative/pulsar-io-kafka 📦

Pulsar IO Kafka Connector

Language: Java - Size: 200 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 24 - Forks: 12

jczuchnowski/zio-pulsar

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

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

streamnative/pulsar-tracing

Tracing instrumentation for Apache Pulsar clients.

Language: Java - Size: 33.2 KB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 21 - Forks: 10

streamnative/pulsar-flume-ng-sink

An Apache Flume Sink implementation to publish data to Apache pulsar

Language: Java - Size: 33.2 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 20 - Forks: 14

apache/pulsar-presto 📦

Pulsar Presto (outdated), go to https://github.com/apache/pulsar-sql instead

Language: Java - Size: 444 KB - Last synced at: 3 days ago - Pushed at: 8 months ago - Stars: 18 - Forks: 5

streamware/nestjs-pulsar

A robust and easy-to-use NestJS module for integrating with Apache Pulsar, enabling efficient message streaming and pub-sub capabilities.

Language: TypeScript - Size: 456 KB - Last synced at: about 13 hours ago - Pushed at: about 1 year ago - Stars: 18 - Forks: 0

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 at: 11 months ago - Pushed at: about 3 years ago - Stars: 18 - Forks: 7

streamnative/pulsar-hub

The canonical source of StreamNative Hub.

Language: JavaScript - Size: 14.5 MB - Last synced at: 13 days ago - Pushed at: 18 days ago - Stars: 17 - Forks: 11

apache/pulsar-java-contrib

Contributor repository for code samples, plugins and libraries in Java for Apache Pulsar

Language: Java - Size: 1.19 MB - Last synced at: 3 days ago - Pushed at: 21 days ago - Stars: 16 - Forks: 6

profunktor/neutron

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

Language: Scala - Size: 1.47 MB - Last synced at: 20 days ago - Pushed at: 25 days ago - Stars: 16 - Forks: 4

streamnative/streamnative-mcp-server

Developer-friendly MCP server bridging Kafka and Pulsar protocols—built with ❤️ by StreamNative for an agentic, streaming-first future.

Language: Go - Size: 2.13 MB - Last synced at: 16 days ago - Pushed at: 16 days ago - Stars: 15 - 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 at: over 2 years ago - Pushed at: about 3 years ago - Stars: 15 - Forks: 5

lhotari/reactive-pulsar-showcase

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

Language: Java - Size: 282 KB - Last synced at: 2 months ago - Pushed at: 7 months ago - Stars: 13 - Forks: 6

pascaldevink/awesome-pulsar

A curated list of Apache Pulsar resources

Size: 10.7 KB - Last synced at: about 4 hours ago - Pushed at: over 6 years ago - Stars: 13 - Forks: 3

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: 83 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 12 - Forks: 7

lhotari/pulsar-spring-cloud-stream-binder

Apache Pulsar binder for Spring Cloud Stream

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

archfish/pulsar_sdk

A pure ruby client for Apache Pulsar

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

flipkart-incubator/pulsar-weighted-consumer

Pulsar consumer clients offering priority consumption

Language: Java - Size: 396 KB - Last synced at: 11 days ago - Pushed at: over 2 years ago - Stars: 11 - Forks: 5

yjshen/spark-connector-test

A tutorial on how to use pulsar-spark-connector

Language: Scala - Size: 12.7 KB - Last synced at: 2 months ago - Pushed at: over 4 years ago - Stars: 11 - Forks: 3

datastax/pulsar-transformations

Language: Java - Size: 39.5 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 10 - Forks: 8

datastax/snowflake-connector

Datastax Snowflake Sink Connector for Apache Pulsar

Language: Java - Size: 90.8 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 9 - Forks: 4

116davinder/apache-pulsar-ansible

Fully Managed Apache Pulsar with Ansible.

Language: HCL - Size: 4.97 MB - Last synced at: 11 months ago - Pushed at: almost 5 years ago - Stars: 9 - Forks: 5

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: 845 KB - Last synced at: about 2 months ago - Pushed at: 8 months ago - Stars: 8 - Forks: 10

bitspire/pulsar-meetup

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

Language: Java - Size: 114 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 8 - Forks: 1

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: 521 KB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 7 - Forks: 1

streamnative/homebrew-streamnative

StreamNative Homebrew Formulae

Language: Ruby - Size: 74.2 KB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 6 - Forks: 3

streamnative/pulsar-io-activemq

ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.

Language: Java - Size: 85 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 6 - Forks: 5

tealtools/dekaf

Dekaf is a visual user interface for Apache Pulsar 🛸

Size: 53.7 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 5 - 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 at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 5 - Forks: 3

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 at: over 2 years ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 6

krvarma/pulsar-ext-scaler-for-keda

Apache Pulsar External Scaler for KEDA

Language: Go - Size: 2.84 MB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 5 - Forks: 4

apache/pulsar-sql

Pulsar SQL extracted from apache/pulsar

Language: Java - Size: 1.3 MB - Last synced at: 4 days ago - Pushed at: 7 months ago - Stars: 4 - Forks: 2

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: 619 KB - Last synced at: 2 months ago - Pushed at: 7 months ago - Stars: 4 - Forks: 2

streamnative/community

StreamNative / Apache Pulsar ecosystem community

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

cbornet/generator-jhipster-pulsar

JHipster module to support Apache Pulsar in your JHipster app

Language: HTML - Size: 548 KB - Last synced at: 9 days ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 2

jbvanzuylen/cf-pulsar-gateway

Apache Pulsar Gateways for ColdFusion

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

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 at: 7 days ago - Pushed at: over 3 years ago - Stars: 4 - Forks: 1

kafkaesque-io/fluent-plugin-pulsar

Fluentd Apache Pulsar output plugin

Language: Ruby - Size: 6.84 KB - Last synced at: over 2 years ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 1

blueshift-labs/neutron

Apache Pulsar client based on C nifs

Language: C - Size: 94.7 KB - Last synced at: 21 days ago - Pushed at: 11 months ago - Stars: 3 - Forks: 2

emc-mongoose/mongoose-storage-driver-pulsar

Apache Pulsar extension for Mongoose

Language: Java - Size: 108 KB - Last synced at: 13 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 2

memgraph/ecommerce-recommender-demo

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

Language: Python - Size: 25.4 KB - Last synced at: about 10 hours ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 0

jmoussa/pulsar-http-client

A FastAPI Pulsar HTTP client.

Language: Python - Size: 29.3 KB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 1

xujakai/pulsar-ansible

使用ansible快速搭建apache pulsar集群

Size: 14.6 KB - Last synced at: about 1 month ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 2

yjshen/pulsar-internals

Apache Pulsar 源码解析

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

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 at: over 2 years ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 2

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.5 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 2 - Forks: 39

anicetkeric/spring-apache-pulsar

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

Language: Java - Size: 69.3 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 5

tealtools/puls

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

Language: Rust - Size: 146 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

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 at: about 1 year ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 2

quiye/pulsar-rust-websocket-client

Rust websocket producer sample codes for Apache Pulsar

Language: Rust - Size: 5.86 KB - Last synced at: 11 months ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 2

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.87 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 83

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 at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 17

davlgd/pulsar-companion

A CLI tool for Apache Pulsar. It allows you to create producers and consumers, send and receive messages, and more

Language: JavaScript - Size: 25.4 KB - Last synced at: about 7 hours ago - Pushed at: 5 months ago - Stars: 1 - Forks: 0

gunh0/pulsar-testbed

🚀 An experimental environment for setting up and testing Apache Pulsar

Language: Go - Size: 346 KB - Last synced at: 3 months ago - Pushed at: 10 months ago - Stars: 1 - Forks: 0

alexandrebrilhante/pulsar-io-questdb

Apache Pulsar sink connector for QuestDB.

Language: Shell - Size: 8.45 MB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 1 - Forks: 0

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 at: 3 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

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 at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 0