This example shows how easy it is to integrate Apache Pulsar with Flow Director's own processing. It defines a connection to a Pulsar broker at the bottom left. A timer is fired every 10 seconds to send a text message containing a simple JSON to a Pulsar topic "my-topic". At the right side we have a Pulsar consumer which receives the messages from that topic and stores it in a local queue "fromPulsar". We could add several other integrations here like Apache Kafka, RabbitMQ, ActiveMQ and so on. The sky is the limit.