kafka

Documentation

Index

• func OpenSubscription(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Subscription, error)
• func OpenTopic(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Topic, error)
• type MSKAccessTokenProvider
  • func (m *MSKAccessTokenProvider) Token() (*sarama.AccessToken, error)

Functions

func OpenSubscription

func OpenSubscription(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Subscription, error)

func OpenTopic

func OpenTopic(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Topic, error)

Types

type MSKAccessTokenProvider

type MSKAccessTokenProvider struct {
	Region      string
	Profile     string
	RoleARN     string
	SessionName string
}

func (*MSKAccessTokenProvider) Token

func (m *MSKAccessTokenProvider) Token() (*sarama.AccessToken, error)