Create topics in kafka with auto create
----------- CREATE TOPICS ----------
CreateTopics Request (Version: 0) => [create_topic_requests] timeout create_topic_requests => topic num_partitions replication_factor [replica_assignment] [configs] topic => STRING num_partitions => INT32 replication_factor => INT16 replica_assignment => partition_id [replicas] partition_id => INT32 replicas => INT32 configs => config_key config_value config_key => STRING config_value => STRING timeout => INT32
CreateTopics Response (Version: 0) => [topic_error_codes] topic_error_codes => topic error_code topic => STRING error_code => INT16
Create topics in kafka with auto create ----------- CREATE TOPICS ---------- CreateTopics Request (Version: 0) => [create_topic_requests] timeout create_topic_requests => topic num_partitions replication_factor [replica_assignment] [configs] topic => STRING num_partitions => INT32 replication_factor => INT16 replica_assignment => partition_id [replicas] partition_id => INT32 replicas => INT32 configs => config_key config_value config_key => STRING config_value => STRING timeout => INT32 CreateTopics Response (Version: 0) => [topic_error_codes] topic_error_codes => topic error_code topic => STRING error_code => INT16
(check-request-package-structure topic)
(create-topic-request buff
{:keys [topic partitions replication-factor]}
timeout-ms)
(create-topic-request-package topic)
(create-topics conn topics timeout-ms)
Write a topic create request to the kafka broker client
response => ( {:topic "mytopic123", :error_code 0})
Write a topic create request to the kafka broker client response => ( {:topic "mytopic123", :error_code 0})
(read-create-topics-response buff)
return [{:topic <topic> :error_code <kafka-error-code>} ....]]
return [{:topic <topic> :error_code <kafka-error-code>} ....]]
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close