helpers

Documentation

Index

• func CreateConsumer(ctx context.Context, client *openapi.APIClient, consumerName string) error
• func CreateKafkaTopicsWithACLs(ctx context.Context, config *kafka.ConfigMap, sourceID, clusterName string) error
• func CreteKafkaPlaceholderTopics(ctx context.Context, config *kafka.ConfigMap, sourceID string) error
• func FindConsumerByName(ctx context.Context, client *openapi.APIClient, consumerName string) (bool, error)
• func NewMaestroAPIClient(maestroServerAddress string) *openapi.APIClient
• type KafkaAdminClient

Functions

func CreateConsumer

func CreateConsumer(ctx context.Context, client *openapi.APIClient, consumerName string) error

func CreateKafkaTopicsWithACLs

func CreateKafkaTopicsWithACLs(ctx context.Context, config *kafka.ConfigMap, sourceID, clusterName string) error

func CreteKafkaPlaceholderTopics

func CreteKafkaPlaceholderTopics(ctx context.Context, config *kafka.ConfigMap, sourceID string) error

CreteKafkaPlaceholderTopics creates placeholder topics. This avoids unknown topic error when subscribing to wildcard topics

func FindConsumerByName

func FindConsumerByName(ctx context.Context, client *openapi.APIClient, consumerName string) (bool, error)

func NewMaestroAPIClient

func NewMaestroAPIClient(maestroServerAddress string) *openapi.APIClient

Types

type KafkaAdminClient

type KafkaAdminClient interface {
	DescribeTopics(ctx context.Context, topics kafka.TopicCollection,
		options ...kafka.DescribeTopicsAdminOption) (result kafka.DescribeTopicsResult, err error)
	DescribeACLs(ctx context.Context, aclBindingFilter kafka.ACLBindingFilter,
		options ...kafka.DescribeACLsAdminOption) (result *kafka.DescribeACLsResult, err error)
	CreateTopics(ctx context.Context, topics []kafka.TopicSpecification,
		options ...kafka.CreateTopicsAdminOption) (result []kafka.TopicResult, err error)
	CreateACLs(ctx context.Context, aclBindings kafka.ACLBindings,
		options ...kafka.CreateACLsAdminOption) (result []kafka.CreateACLResult, err error)
}

an interface for kafka.AdminClient, this will help with testing