example pulsar client using basic auth in clojure

readme.org

# run main
clj -X:run
# rebel readline shell
clj -A:rebel

core.clj

(ns pulsar-test.core
  (:import (org.apache.pulsar.client.api PulsarClient)))

(defn make-consumer
  []
  (let [props (doto (java.util.Properties.)
                (.putAll {"userId" "super"
                          "password" "superpass"}))
        client (-> (PulsarClient/builder)
                   (.serviceUrl "pulsar://localhost:6650")
                   (.authentication
                    "org.apache.pulsar.client.impl.auth.AuthenticationBasic"
                    props)
                   (.build))
        consumer (-> (.newConsumer client)
                     (.topics ["my-topic"])
                     (.subscriptionName "my-sub")
                     (.subscribe))]
    consumer))

(defn -main
  [& _args]
  (let [consumer (make-consumer)
        message (.receive consumer)]
    (println (String. (.getData message)))
    (System/exit 0)))

deps.edn

{:deps {org.apache.pulsar/pulsar-client {:mvn/version "2.10.0"}}
 :aliases {:rebel {:extra-deps {com.bhauman/rebel-readline {:mvn/version "0.1.4"}}
                   :main-opts  ["-m" "rebel-readline.main"]}
           :run {:exec-fn pulsar-test.core/-main}}}