MCPcopy
hub / github.com/IBM/sarama / CreateTopic

Method CreateTopic

admin.go:24–24  ·  view source on GitHub ↗

Creates a new topic. This operation is supported by brokers with version 0.10.1.0 or higher. It may take several seconds after CreateTopic returns success for all the brokers to become aware that the topic has been created. During this time, listTopics may not return information about the new topic.

(topic string, detail *TopicDetail, validateOnly bool)

Source from the content-addressed store, hash-verified

22 // to become aware that the topic has been created. During this time, listTopics
23 // may not return information about the new topic.The validateOnly option is supported from version 0.10.2.0.
24 CreateTopic(topic string, detail *TopicDetail, validateOnly bool) error
25
26 // List the topics available in the cluster with the default options.
27 ListTopics() (map[string]TopicDetail, error)

Implementers 1

clusterAdminadmin.go

Calls

no outgoing calls