Hands-on Workshop: Apache Pulsar

Apache Pulsar Hands-on workshop outline:

1. Pulsar overview

2. Architecture Overview

3. Pulsar Messaging Model

3.1 Namespace

3.2 Explaining Shared subscription vs Exclusive subscription

3.3 Demo: pulsar-java-tutorial (https://github.com/streamlio/pulsar-java-tutorial)

3.3.1 Basic Producer, Consumer

3.3.2 Shared, Exclusive, Failure

3.4 Demo: python-java-tutorial (https://github.com/streamlio/pulsar-python-tutorial)

3.5 Explain Individual Acknowledgement vs Cumulative Acknowledgement

3.5.1 Demo: Difference between Individual Ack vs Cumulative Ack

3.6 Demo: Migrate an existing Kafka application with no code change to Pulsar

LUNCH BREAK

4. Multi-tenancy & Enterprise features (demo)

4.1 Security: Enable authentication and authorization

4.2. How to setup storage quota, enable flow control and rate limiting

4.3 How to do hardware isolation

5. Geo Replication (Group exercise)

5.1 Demo: Setting a global cluster between groups

5.2 Demo: Different patterns

5.2.1 Full-Mesh

5.2.2 Active-Standby

5.2.3 Aggregation

SPEAKER BIOGRAPHIES:

• Matteo Merli is a software engineer at Streamlio, where he works on messaging and storage technologies. Previously, he spent several years building database replication systems and multi-tenant messaging platforms at Yahoo. Matteo was the architect and lead developer for Pulsar and is a PMC member of Apache BookKeeper.

• Sijie Guo is the Co-founder of Streamlio, a company focused on building a next-generation real-time data stack. Previously, he was the tech lead for the messaging group at Twitter, where he co-created Apache DistributedLog, and worked on push notification infrastructure at Yahoo. He is the PMC chair of Apache BookKeeper.