Liking cljdoc? Tell your friends :D
Clojure only.

ziggurat.config

-getclj

(-get key)
source

-getInclj

(-getIn keys)
source

build-consumer-config-propertiesclj

source

build-producer-config-propertiesclj

source

build-propertiesclj

(build-properties set-property-fn config-map)

Builds Properties object from the provided config-map which is a map where keys are Clojure keywords in kebab case. These keys are converted to Kafka properties by set-property-fn.

First, ssl properties are set using the config map returned by a call to ssl-config

Then, properties from the provided config-map are applied. config-map can carry properties for Streams, Consumer or Producer APIs

The method allows individual Streams, Producer, Consumer APIs to override SSL configs if ssl properties are provided in config-map

Example of a config-map for streams {:auto-offset-reset :latest :replication-factor 2 :group-id "foo"}

Builds Properties object from the provided config-map which is a map where keys are
Clojure keywords in kebab case. These keys are converted to Kafka properties by set-property-fn.

First, ssl properties are set using the config map returned by a call to `ssl-config`

Then, properties from the provided `config-map` are applied. `config-map` can carry properties for Streams,
Consumer or Producer APIs

The method allows individual Streams, Producer, Consumer APIs to override SSL configs
if ssl properties are provided in `config-map`

Example of a config-map for streams
 {:auto-offset-reset   :latest
  :replication-factor  2
  :group-id            "foo"}
sourceraw docstring

build-ssl-propertiesclj

(build-ssl-properties properties set-property-fn ssl-config-map)
source

build-streams-config-propertiesclj

source

channel-retry-configclj

(channel-retry-config topic-entity channel)
source

configclj

source

config-fileclj

source

config-from-envclj

(config-from-env config-file)
source

consumer-config-mapping-tableclj

source

create-jaas-propertiesclj

(create-jaas-properties user-name password mechanism)
source

default-configclj

source

get-channel-retry-countclj

(get-channel-retry-count topic-entity channel)
source

get-configured-retry-countclj

(get-configured-retry-count)
source

get-in-configclj

(get-in-config ks)
(get-in-config ks default)
source

jaas-templateclj

source

producer-config-mapping-tableclj

source

rabbitmq-configclj

(rabbitmq-config)
source

set-propertyclj

(set-property mapping-table p k v)
source

ssl-configclj

(ssl-config)
source

statsd-configclj

(statsd-config)
source

streams-config-mapping-tableclj

source

ziggurat-configclj

(ziggurat-config)
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close