broker

Feb 26, 2024

Changes in this version

type Configuration

+ Addresses string

+ ClientID string

+ DisplayMessageWithWrongStructure bool

+ type SCRAMClient struct

+ func (x *SCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *SCRAMClient) Done() bool

+ func (x *SCRAMClient) Step(challenge string) (response string, err error)

Aug 31, 2022

Changes in this version

+ func SaramaConfigFromBrokerConfig(cfg Configuration) (*sarama.Config, error)

type Configuration

+ CertPath string

+ SaslMechanism string

+ SaslPassword string

+ SaslUsername string

+ SecurityProtocol string

Jan 24, 2022

Changes in this version

type Configuration

+ DeadLetterQueueTopic string

Oct 1, 2020

Changes in this version

type Configuration

+ OrgAllowlist mapset.Set

+ OrgAllowlistEnabled bool

+ Timeout time.Duration

Jul 8, 2020

Changes in this version

+ type Configuration struct

+ Address string

+ Enabled bool

+ Group string

+ OrgWhitelist mapset.Set

+ OrgWhitelistEnabled bool

+ PayloadTrackerTopic string

+ ServiceName string

+ Topic string