broker

Documentation

Overview

Package broker contains data types, interfaces, and methods related to brokers that can be used to consume input messages by aggegator.

Index

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

Functions

func SaramaConfigFromBrokerConfig

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

SaramaConfigFromBrokerConfig returns a Config struct from broker.Configuration parameters

Types

type Configuration

type Configuration struct {
	Address              string        `mapstructure:"address" toml:"address"`
	SecurityProtocol     string        `mapstructure:"security_protocol" toml:"security_protocol"`
	CertPath             string        `mapstructure:"cert_path" toml:"cert_path"`
	SaslMechanism        string        `mapstructure:"sasl_mechanism" toml:"sasl_mechanism"`
	SaslUsername         string        `mapstructure:"sasl_username" toml:"sasl_username"`
	SaslPassword         string        `mapstructure:"sasl_password" toml:"sasl_password"`
	Topic                string        `mapstructure:"topic" toml:"topic"`
	Timeout              time.Duration `mapstructure:"timeout" toml:"timeout"`
	PayloadTrackerTopic  string        `mapstructure:"payload_tracker_topic" toml:"payload_tracker_topic"`
	DeadLetterQueueTopic string        `mapstructure:"dead_letter_queue_topic" toml:"dead_letter_queue_topic"`
	ServiceName          string        `mapstructure:"service_name" toml:"service_name"`
	Group                string        `mapstructure:"group" toml:"group"`
	Enabled              bool          `mapstructure:"enabled" toml:"enabled"`
	OrgAllowlist         mapset.Set    `mapstructure:"org_allowlist_file" toml:"org_allowlist_file"`
	OrgAllowlistEnabled  bool          `mapstructure:"enable_org_allowlist" toml:"enable_org_allowlist"`
}

Configuration represents configuration of Kafka broker