amazonica.aws.kafka — com.signal-ai/amazonica 0.3.167-signal-4

batch-associate-scram-secret clj

(batch-associate-scram-secret &
                              {:keys [cluster-arn secret-arn-list]
                               :as batch-associate-scram-secret-request})

batch-disassociate-scram-secret clj

(batch-disassociate-scram-secret &
                                 {:keys [cluster-arn secret-arn-list]
                                  :as batch-disassociate-scram-secret-request})

client-class clj

create-cluster clj

(create-cluster &
                {:keys [broker-node-group-info client-authentication
                        cluster-name configuration-info encryption-info
                        enhanced-monitoring kafka-version logging-info
                        number-of-broker-nodes open-monitoring tags]
                 :as create-cluster-request})

create-cluster-v2 clj

(create-cluster-v2 &
                   {:keys [cluster-name provisioned serverless tags]
                    :as create-cluster-v2-request})

create-configuration clj

(create-configuration &
                      {:keys [description kafka-versions name server-properties]
                       :as create-configuration-request})

delete-cluster clj

(delete-cluster &
                {:keys [cluster-arn current-version]
                 :as delete-cluster-request})

delete-configuration clj

(delete-configuration & {:keys [arn] :as delete-configuration-request})

describe-cluster clj

(describe-cluster & {:keys [cluster-arn] :as describe-cluster-request})

describe-cluster-operation clj

(describe-cluster-operation &
                            {:keys [cluster-operation-arn]
                             :as describe-cluster-operation-request})

describe-cluster-v2 clj

(describe-cluster-v2 & {:keys [cluster-arn] :as describe-cluster-v2-request})

describe-configuration clj

(describe-configuration & {:keys [arn] :as describe-configuration-request})

describe-configuration-revision clj

(describe-configuration-revision &
                                 {:keys [arn revision]
                                  :as describe-configuration-revision-request})

get-bootstrap-brokers clj

(get-bootstrap-brokers &
                       {:keys [cluster-arn] :as get-bootstrap-brokers-request})

get-cached-response-metadata clj

(get-cached-response-metadata & [amazon-web-service-request])

get-compatible-kafka-versions clj

(get-compatible-kafka-versions &
                               {:keys [cluster-arn]
                                :as get-compatible-kafka-versions-request})

list-cluster-operations clj

(list-cluster-operations &
                         {:keys [cluster-arn max-results next-token]
                          :as list-cluster-operations-request})

list-clusters clj

(list-clusters &
               {:keys [cluster-name-filter max-results next-token]
                :as list-clusters-request})

list-clusters-v2 clj

(list-clusters-v2 &
                  {:keys [cluster-name-filter cluster-type-filter max-results
                          next-token]
                   :as list-clusters-v2-request})

list-configuration-revisions clj

(list-configuration-revisions &
                              {:keys [arn max-results next-token]
                               :as list-configuration-revisions-request})

list-configurations clj

(list-configurations &
                     {:keys [max-results next-token]
                      :as list-configurations-request})

list-kafka-versions clj

(list-kafka-versions &
                     {:keys [max-results next-token]
                      :as list-kafka-versions-request})

list-nodes clj

(list-nodes &
            {:keys [cluster-arn max-results next-token] :as list-nodes-request})

list-scram-secrets clj

(list-scram-secrets &
                    {:keys [cluster-arn max-results next-token]
                     :as list-scram-secrets-request})

list-tags-for-resource clj

(list-tags-for-resource &
                        {:keys [resource-arn]
                         :as list-tags-for-resource-request})

reboot-broker clj

(reboot-broker & {:keys [broker-ids cluster-arn] :as reboot-broker-request})

show-functions clj

shutdown clj

(shutdown)

tag-resource clj

(tag-resource & {:keys [resource-arn tags] :as tag-resource-request})

untag-resource clj

(untag-resource & {:keys [resource-arn tag-keys] :as untag-resource-request})

update-broker-count clj

(update-broker-count &
                     {:keys [cluster-arn current-version
                             target-number-of-broker-nodes]
                      :as update-broker-count-request})

update-broker-storage clj

(update-broker-storage &
                       {:keys [cluster-arn current-version
                               target-broker-ebs-volume-info]
                        :as update-broker-storage-request})

update-broker-type clj

(update-broker-type &
                    {:keys [cluster-arn current-version target-instance-type]
                     :as update-broker-type-request})

update-cluster-configuration clj

(update-cluster-configuration &
                              {:keys [cluster-arn configuration-info
                                      current-version]
                               :as update-cluster-configuration-request})

update-cluster-kafka-version clj

(update-cluster-kafka-version &
                              {:keys [cluster-arn configuration-info
                                      current-version target-kafka-version]
                               :as update-cluster-kafka-version-request})

update-configuration clj

(update-configuration &
                      {:keys [arn description server-properties]
                       :as update-configuration-request})

update-connectivity clj

(update-connectivity &
                     {:keys [cluster-arn connectivity-info current-version]
                      :as update-connectivity-request})

update-monitoring clj

(update-monitoring &
                   {:keys [cluster-arn current-version enhanced-monitoring
                           logging-info open-monitoring]
                    :as update-monitoring-request})

update-security clj

(update-security &
                 {:keys [client-authentication cluster-arn current-version
                         encryption-info]
                  :as update-security-request})