Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OpenSubscription ¶
func OpenSubscription(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Subscription, error)
Types ¶
type MSKAccessTokenProvider ¶ added in v0.32.0
type MSKAccessTokenProvider struct { Region string Profile string RoleARN string SessionName string }
func (*MSKAccessTokenProvider) Token ¶ added in v0.32.0
func (m *MSKAccessTokenProvider) Token() (*sarama.AccessToken, error)
Click to show internal directories.
Click to hide internal directories.