kafka

Oct 24, 2024

Changes in this version

type ConsumerConfig

+ QueueCapacity int

Sep 3, 2024

Changes in this version

+ var NonStopWork time.Duration = 0

+ type Headers []Header

+ func (hs Headers) Pretty() string

Jun 3, 2024

Changes in this version

type ConsumerConfig

+ VerifyTopicOnStartup bool

May 30, 2024

Changes in this version

type Config

+ func (c *Config) GetBrokerAddr() net.Addr

type ProducerConfig

+ Brokers []string

Mar 28, 2024

Changes in this version

type ProducerConfig

+ Balancer segmentio.Balancer

Feb 18, 2024

Changes in this version

type Config

+ MetricPrefix string

Feb 11, 2024

Changes in this version

type ConsumerConfig

+ SkipMessageByHeaderFn SkipMessageByHeaderFn

+ type SkipMessageByHeaderFn func(headers []Header) bool

Dec 10, 2023

Changes in this version

type Message

+ func (m *Message) AddHeader(header Header)

Nov 16, 2023

Changes in this version

+ const ExponentialBackOffStrategy

+ const FixedBackOffStrategy

+ const LinearBackOffStrategy

+ type BackoffStrategyInterface interface

+ ShouldIncreaseRetryAttemptCount func(retryCount int, retryAttemptCount int) bool

+ String func() string

+ func GetBackoffStrategy(strategyName string) BackoffStrategyInterface

type ConsumerConfig

+ BackOffStrategy BackoffStrategyInterface

+ type ExponentialBackoffStrategy struct

+ func (s *ExponentialBackoffStrategy) ShouldIncreaseRetryAttemptCount(retryCount int, retryAttemptCount int) bool

+ func (s *ExponentialBackoffStrategy) String() string

+ type FixedBackoffStrategy struct

+ func (s *FixedBackoffStrategy) ShouldIncreaseRetryAttemptCount(_ int, _ int) bool

+ func (s *FixedBackoffStrategy) String() string

+ type LinearBackoffStrategy struct

+ func (s *LinearBackoffStrategy) ShouldIncreaseRetryAttemptCount(retryCount int, retryAttemptCount int) bool

+ func (s *LinearBackoffStrategy) String() string

Aug 19, 2023

Changes in this version

type Cronsumer

+ GetMetricCollectors func() []prometheus.Collector

Jun 19, 2023

Changes in this version

type ConsumerConfig

+ ClientID string

Jun 15, 2023

Changes in this version

type Config

+ ClientID string

type Cronsumer

+ ProduceBatch func(messages []Message) error

Jun 5, 2023

Changes in this version

+ const OffsetEarliest

+ const OffsetLatest

Apr 15, 2023

Changes in this version

type Offset

+ func ToStringOffset(offset int64) Offset

Dec 30, 2022

Changes in this version

type Cronsumer

+ Produce func(message Message) error

+ type Header struct

+ Key string

+ Value []byte

+ type MessageBuilder struct

+ func NewMessageBuilder() *MessageBuilder

+ func (mb *MessageBuilder) Build() Message

+ func (mb *MessageBuilder) WithHeaders(headers []Header) *MessageBuilder

+ func (mb *MessageBuilder) WithHighWatermark(highWaterMark int64) *MessageBuilder

+ func (mb *MessageBuilder) WithKey(key []byte) *MessageBuilder

+ func (mb *MessageBuilder) WithPartition(partition int) *MessageBuilder

+ func (mb *MessageBuilder) WithTopic(topic string) *MessageBuilder

+ func (mb *MessageBuilder) WithValue(value []byte) *MessageBuilder

Dec 5, 2022

Changes in this version

+ type Config struct

+ Brokers []string

+ Consumer ConsumerConfig

+ LogLevel logger.Level

+ Logger logger.Interface

+ Producer ProducerConfig

+ SASL SASLConfig

+ func (c *Config) SetDefaults()

+ func (c *Config) Validate()

+ type ConsumeFn func(message Message) error

+ type ConsumerConfig struct

+ CommitInterval time.Duration

+ Concurrency int

+ Cron string

+ DeadLetterTopic string

+ Duration time.Duration

+ GroupID string

+ HeartbeatInterval time.Duration

+ MaxBytes int

+ MaxRetry int

+ MaxWait time.Duration

+ MinBytes int

+ RebalanceTimeout time.Duration

+ RetentionTime time.Duration

+ SessionTimeout time.Duration

+ StartOffset Offset

+ Topic string

+ type Cronsumer interface

+ Run func()

+ Start func()

+ Stop func()

+ WithLogger func(logger logger.Interface)

+ type Message struct

+ Headers []protocol.Header

+ HighWaterMark int64

+ Key []byte

+ Offset int64

+ Partition int

+ Time time.Time

+ Topic string

+ Value []byte

+ type Offset string

+ func (o Offset) Value() int64

+ type ProducerConfig struct

+ BatchSize int

+ BatchTimeout time.Duration

+ type SASLConfig struct

+ AuthType string

+ Enabled bool

+ IntermediateCAPath string

+ Password string

+ Rack string

+ RootCAPath string

+ Username string