topic

Documentation

Index

• type Topic
  • func New(v string, brk []string) (*Topic, error)
  • func NewWithClusterAdmin(admin sarama.ClusterAdmin) *Topic
  • func (t *Topic) CreateTopic(topic string, pc int32, rc int16) (err error)
  • func (t *Topic) DeleteTopic(topic string) (err error)
  • func (t *Topic) GetAllTopics() ([]string, error)
  • func (t *Topic) IsTopicAlreadyCreated(topic string) (exists bool, err error)

Types

type Topic

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

Topic provides kafka-topic management functions.

func New

func New(v string, brk []string) (*Topic, error)

New to create a new Topic

func NewWithClusterAdmin

func NewWithClusterAdmin(admin sarama.ClusterAdmin) *Topic

NewWithClusterAdmin to create new Topic with already created ClusterAdmin

func (*Topic) CreateTopic

func (t *Topic) CreateTopic(topic string, pc int32, rc int16) (err error)

CreateTopic creates a new Topic in Kafka

func (*Topic) DeleteTopic

func (t *Topic) DeleteTopic(topic string) (err error)

DeleteTopic deletes a Topic in Kafka

func (*Topic) GetAllTopics

func (t *Topic) GetAllTopics() ([]string, error)

GetAllTopics fetches all topic names that are created in Kafka

func (*Topic) IsTopicAlreadyCreated

func (t *Topic) IsTopicAlreadyCreated(topic string) (exists bool, err error)

IsTopicAlreadyCreated checks if topic is already created in Kafka