Liking cljdoc? Tell your friends :D
Clojure only.
- -get
- -getIn
- build-consumer-config-properties
- build-producer-config-properties
- build-properties
- build-ssl-properties
- build-streams-config-properties
- channel-retry-config
- config
- config-file
- config-from-env
- consumer-config-mapping-table
- create-jaas-properties
- default-config
- get-channel-retry-count
- get-configured-retry-count
- get-in-config
- jaas-template
- producer-config-mapping-table
- prometheus-config
- rabbitmq-config
- set-property
- ssl-config
- statsd-config
- streams-config-mapping-table
- ziggurat-config
ziggurat.config
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"}
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close