Documentation ¶
Overview ¶
This file is auto-generated, don't edit it. Thanks. aliyun doc https://help.aliyun.com/document_detail/437673.html aliyun debug https://next.api.aliyun.com/api/alikafka/2019-09-16/CreateTopic?lang=GO
Index ¶
- func CreateClient(accessKeyId *string, accessKeySecret *string) (_result *alikafka20190916.Client, _err error)
- type Admin
- type AdminSource
- func (a *AdminSource) Admin()
- func (a *AdminSource) Client()
- func (a *AdminSource) CreateTopic(topicName string, numPartition, numReplication int64) (err error)
- func (a *AdminSource) DoConsumer1()
- func (a *AdminSource) DoConsumer2()
- func (a *AdminSource) DoProducer()
- func (a *AdminSource) ListAcls() ([]sarama.ResourceAcls, error)
- func (a *AdminSource) ListTopic() (map[string]sarama.TopicDetail, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateClient ¶
func CreateClient(accessKeyId *string, accessKeySecret *string) (_result *alikafka20190916.Client, _err error)
*
- 使用AK&SK初始化账号Client
- @param accessKeyId
- @param accessKeySecret
- @return Client
- @throws Exception
Types ¶
type Admin ¶
type Admin interface { Client() Admin() ListTopic() (map[string]sarama.TopicDetail, error) }
type AdminSource ¶
type AdminSource struct {
// contains filtered or unexported fields
}
func (*AdminSource) Admin ¶
func (a *AdminSource) Admin()
func (*AdminSource) Client ¶
func (a *AdminSource) Client()
func (*AdminSource) CreateTopic ¶
func (a *AdminSource) CreateTopic(topicName string, numPartition, numReplication int64) (err error)
func (*AdminSource) DoConsumer1 ¶
func (a *AdminSource) DoConsumer1()
func (*AdminSource) DoConsumer2 ¶
func (a *AdminSource) DoConsumer2()
func (*AdminSource) DoProducer ¶
func (a *AdminSource) DoProducer()
func (*AdminSource) ListAcls ¶
func (a *AdminSource) ListAcls() ([]sarama.ResourceAcls, error)
func (*AdminSource) ListTopic ¶
func (a *AdminSource) ListTopic() (map[string]sarama.TopicDetail, error)
Click to show internal directories.
Click to hide internal directories.