topic_manager

Documentation

Index

• type TopicManager
  • func New() *TopicManager
  • func (tm *TopicManager) Close()
  • func (tm *TopicManager) DeleteTopic(name string) error
  • func (tm *TopicManager) UpsertTopic(name string, partitions int, replicas int, config map[string]string) error

Types

type TopicManager

type TopicManager struct {
	// contains filtered or unexported fields
}

func New

func New() *TopicManager

func (*TopicManager) Close

func (tm *TopicManager) Close()

func (*TopicManager) DeleteTopic

func (tm *TopicManager) DeleteTopic(name string) error

func (*TopicManager) UpsertTopic

func (tm *TopicManager) UpsertTopic(name string, partitions int, replicas int, config map[string]string) error