Versions in this module Expand all Collapse all v1 v1.0.0 Sep 27, 2022 Changes in this version + const CommitRateLessThanOrEqualZero + const DefaultCommitRate + const DefaultQueueSize + const DefaultRebalanceStrategy + const DefaultTopicIn + const DefaultTopicOut + const EnvNameCommitRate + const EnvNameKafkaBrokers + const EnvNameKafkaClientId + const EnvNameKafkaEnableLog + const EnvNameKafkaGroupId + const EnvNameKafkaQueueSize + const EnvNameKafkaTopicIn + const EnvNameKafkaTopicOut + const EnvNameRebalanceStrategy + const NoBrokersConfigured + const NoClientIdConfigured + const NoGroupIdConfigured + const UnsupportedTypef + var DefaultBrokers = []string + var ErrCommitRateLessThanOrEqualZero = errors.New(CommitRateLessThanOrEqualZero) + var ErrNoBrokersConfigured = errors.New(NoBrokersConfigured) + var ErrNoClientIdConfigured = errors.New(NoClientIdConfigured) + var ErrNoGroupIdConfigured = errors.New(NoGroupIdConfigured) + func New(parameters ...interface{}) interface + type Configuration struct + Brokers []string + ClientId string + CommitRate time.Duration + EnableLog bool + GroupId string + QueueSize int + RebalanceStrategy string + TopicIn string + TopicOut string + func (c *Configuration) Default() + func (c *Configuration) FromEnv(envs map[string]string) + func (c *Configuration) ToKafka() ([]string, *sarama.Config) + func (c *Configuration) Validate() error + type ErrorHandlerFx func(error) + type Example struct + func (e *Example) MarshalBinary() ([]byte, error) + func (e *Example) UnmarshalBinary(bytes []byte) error + type Owner interface + Initialize func(config *Configuration) (err error) + Shutdown func() + type Wrapper struct + func WrapperConvertMultiple(items []interface{}) []*Wrapper + func WrapperConvertSingle(item interface{}) *Wrapper + func (w *Wrapper) FromWrapper() (interface{}, error) + func (w *Wrapper) MarshalBinary() ([]byte, error) + func (w *Wrapper) ToWrapper(message proto.Message) error + func (w *Wrapper) UnmarshalBinary(bytes []byte) error
Go to main page