====== Pulsar ======

<code>
wget https://archive.apache.org/dist/pulsar/pulsar-2.4.1/apache-pulsar-2.4.1-bin.tar.gz
tar xvfz apache-pulsar-2.4.1-bin.tar.gz
cd apache-pulsar-2.4.1

# connectors


# storage
wget https://archive.apache.org/dist/pulsar/pulsar-2.4.1/apache-pulsar-offloaders-2.4.1-bin.tar.gz
tar xvfz apache-pulsar-offloaders-2.4.1-bin.tar.gz
mv apache-pulsar-offloaders-2.4.1/offloaders offloaders

</code>

===== storage s3 =====

conf/broker.conf
<code>
...
managedLedgerOffloadDriver=S3
s3ManagedLedgerOffloadBucket=pulsar-topic-offload
s3ManagedLedgerOffloadRegion=
s3ManagedLedgerOffloadServiceEndpoint=http://127.0.0.1:9000
...
</code>


conf/pulsar_env.sh
<code>
export AWS_ACCESS_KEY_ID=ABC123456789
export AWS_SECRET_ACCESS_KEY=ded7db27a4558e2ea8bbf0bf37ae0e8521618f366c
</code>


run
<code>
bin/pulsar standalone
</code>

define a storage threshold in "public" tenant, default name space
<code>
bin/pulsar-admin namespaces set-offload-threshold  --size 0 public/default
</code>


===== test =====

first shell
<code>
bin/pulsar-client consume my-topic -s "first-subscription"
</code>

second shell
<code>
bin/pulsar-client produce my-topic --messages "hello-pulsar" -n 1000
</code>