kafka

Documentation

Index

• Variables
• func NewAdminClient(ctx context.Context, brokers []string, saramaConfig *sarama.Config) (types.AdminClientInterface, error)
• type KafkaAdminClient
  • func (k KafkaAdminClient) Close() error
  • func (k KafkaAdminClient) CreateTopic(_ context.Context, topicName string, topicDetail *sarama.TopicDetail) *sarama.TopicError
  • func (k KafkaAdminClient) DeleteTopic(_ context.Context, topicName string) *sarama.TopicError

Variables

var NewClusterAdminFn = func(brokers []string, config *sarama.Config) (sarama.ClusterAdmin, error) {
	return sarama.NewClusterAdmin(brokers, config)
}

Sarama NewClusterAdmin() Wrapper Function Variable To Facilitate Unit Testing

Functions

func NewAdminClient

func NewAdminClient(ctx context.Context, brokers []string, saramaConfig *sarama.Config) (types.AdminClientInterface, error)

Create A New Kafka AdminClient Based On The Kafka Secret In The Specified K8S Namespace

Types

type KafkaAdminClient

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

Kafka AdminClient Definition

func (KafkaAdminClient) Close

func (k KafkaAdminClient) Close() error

Sarama Pass-Through Function For Closing ClusterAdmin

func (KafkaAdminClient) CreateTopic

func (k KafkaAdminClient) CreateTopic(_ context.Context, topicName string, topicDetail *sarama.TopicDetail) *sarama.TopicError

Sarama Pass-Through Function For Creating Topics

func (KafkaAdminClient) DeleteTopic

func (k KafkaAdminClient) DeleteTopic(_ context.Context, topicName string) *sarama.TopicError

Sarama Pass-Through Function For Deleting Topics