Show pageOld revisionsBacklinksAdd to bookExport to PDFBack to top This page is read only. You can view the source, but not change it. Ask your administrator if you think this is wrong. ====== 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> tips/pulsar.txt Last modified: 2019/09/23 15:44by scipio