Pinned Repositories
cluster-failover-demo
GottaEat
Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book
GottaEat-UI
User interface components for the GottaEat food delivery service application
incubator-edgent
Mirror of Apache Edgent (Incubating)
multi-protocol-pulsar
Pulsar-Edge-Analytics
A collection of Pulsar Functions that perform streaming analytics on edge devices
pulsar-in-action
The code repository for the "Pulsar in Action" book by Manning press
pulsar-in-action-python
pulsar-mop-demo
An self-contained MQTT environment and application in Apache Pulsar
pulsar-nifi-bundle
NiFi Processor for Apache Pulsar
david-streamlio's Repositories
david-streamlio/pulsar-nifi-bundle
NiFi Processor for Apache Pulsar
david-streamlio/multi-protocol-pulsar
david-streamlio/pulsar-mop-demo
An self-contained MQTT environment and application in Apache Pulsar
david-streamlio/microk8s-install
Documentation of the steps to install microk8s in my lab environment
david-streamlio/table-view-demo
A collection of demonstrations of Pulsar's TableView API
david-streamlio/coinbase-functions
david-streamlio/error-handling-in-pulsar
A framework for demonstrating the behavior or various error handling patterns in Apache Pulsar
david-streamlio/pulsar
Apache Pulsar - distributed pub-sub messaging system
david-streamlio/pulsar-aop-demo
david-streamlio/pulsar-on-k8s
david-streamlio/zero-to-hero
Code for "From Zero to Streaming Hero" conference talk
david-streamlio/ably-live-feed
david-streamlio/auto-scaling-function-demo
david-streamlio/awesome-public-real-time-datasets
A list of publicly available datasets with real-time data maintained by the team at bytewax.io
david-streamlio/clickstream-generator
Pulsar IO equivalent of the Flink DataGen class
david-streamlio/coinbase-live-feed
david-streamlio/coinbase-volatility-tracker
david-streamlio/coinbase-websocket-feed-router
A Pulsar function that performs parsing and content based routing of messages from the Coinbase websocket channels
david-streamlio/flink-and-pulsar-on-k8s
david-streamlio/oxia-intro
A quick demo of Oxia using a Java client
david-streamlio/pulsar-functions-java-buildpack
david-streamlio/pulsar-jms-cts
david-streamlio/pulsar-kop-demo
A self-contained KoP enabled demo including a Dockerfile and demo code
david-streamlio/reactive-pulsar-showcase
SpringBoot show case application for pulsar-client-reactive library (Reactive Client for Apache Pulsar)
david-streamlio/Real-Time-Cryptocurrency-Analytics
david-streamlio/sentiment-analysis
Pulsar Function that performs sentiment analysis on incoming text sentence, e.g., tweets.
david-streamlio/spark-and-pulsar-on-k8s
david-streamlio/SpeakerProfile
david-streamlio/trino-and-pulsar-on-k8s
david-streamlio/zero-to-hero-workshop
Workshop for stream processing