Versions in this module Expand all Collapse all v1 v1.0.0 Oct 2, 2023 Changes in this version + type Admin struct + BootstrapServers []string + ClientId string + CreateTopicTimeout time.Duration + SecurityProtocol string + Tls *Tls + func (p Admin) GetClientId() string + func (p Admin) GetSecurityProtocol() string + func (p Admin) GetTls() *Tls + type Client struct + Admin Admin + BootstrapServers []string + ClientId string + Consumer Consumer + Debug bool + Producer Producer + SecurityProtocol string + Tls *Tls + Version string + func NewClient(loader config.Loader) (*Client, error) + func (p *Client) PostBinding() error + func (p Client) Prefix() string + type Consumer struct + BootstrapServers []string + ClientId string + CommitMode string + InitialOffset int64 + SecurityProtocol string + Tls *Tls + func (p Consumer) GetClientId() string + func (p Consumer) GetSecurityProtocol() string + func (p Consumer) GetTls() *Tls + type EventProducer struct + EventMappings map[string]EventTopic + func NewEventProducer(loader config.Loader) (*EventProducer, error) + func (p EventProducer) Prefix() string + type EventTopic struct + Disable bool + TopicName string + Transactional bool + type KafkaConsumer struct + HandlerMappings map[string]TopicConsumer + func NewKafkaConsumer(loader config.Loader) (*KafkaConsumer, error) + func (c KafkaConsumer) Prefix() string + type Producer struct + BootstrapServers []string + ClientId string + FlushFrequency time.Duration + FlushMessages int + SecurityProtocol string + Tls *Tls + func (p Producer) GetClientId() string + func (p Producer) GetSecurityProtocol() string + func (p Producer) GetTls() *Tls + type Tls struct + CaFileLocation string + CertFileLocation string + InsecureSkipVerify bool + KeyFileLocation string + type TopicAdmin struct + Topics []core.TopicConfiguration + func NewTopicAdmin(loader config.Loader) (*TopicAdmin, error) + func (h TopicAdmin) Prefix() string + type TopicConsumer struct + Concurrency int + Enable bool + GroupId string + Topic string + Topics []string