topic

Documentation

Index

• type KafkaClient
  • func (client *KafkaClient) Close() error
  • func (client *KafkaClient) Create(kt *v1alpha1.KafkaTopic) error
  • func (client *KafkaClient) Delete(topic string) error
  • func (client *KafkaClient) DeleteIfExists(topic string) error
  • func (client *KafkaClient) Exists(topic string) (bool, error)
  • func (client *KafkaClient) Init(kc *v1alpha1.KafkaConnection) error
  • func (client *KafkaClient) Update(kt *v1alpha1.KafkaTopic) error

Types

type KafkaClient

type KafkaClient struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func (*KafkaClient) Close

func (client *KafkaClient) Close() error

Close terminates the connection

func (*KafkaClient) Create

func (client *KafkaClient) Create(kt *v1alpha1.KafkaTopic) error

Create creates a topic on the target

func (*KafkaClient) Delete

func (client *KafkaClient) Delete(topic string) error

Delete removes the topic from target

func (*KafkaClient) DeleteIfExists

func (client *KafkaClient) DeleteIfExists(topic string) error

func (*KafkaClient) Exists

func (client *KafkaClient) Exists(topic string) (bool, error)

Exists checks if a topic already exists on the target

func (*KafkaClient) Init

func (client *KafkaClient) Init(kc *v1alpha1.KafkaConnection) error

Init initialises the the admin client

func (*KafkaClient) Update

func (client *KafkaClient) Update(kt *v1alpha1.KafkaTopic) error

Update allows for changes in the topic config