kafka

Jan 6, 2024

Changes in this version

type Client

+ func (k *Client) ListenTopic(topic string, f HandlerFunc) error

type IClient

+ CreateTopic func(topic string, numPart int) error

+ ListenTopic func(topic string, f HandlerFunc) error

Dec 22, 2023

Changes in this version

type Message

+ Retry int

Dec 21, 2023

Changes in this version

+ type Event struct

+ Data []byte

+ EventID string

+ EventType EventType

+ Metadata []byte

+ Timestamp time.Time

+ Version uint64

+ func NewEvent(eventType EventType, data []byte, metadata ...[]byte) *Event

+ func (e *Event) GetData() []byte

+ func (e *Event) GetEventID() string

+ func (e *Event) GetEventType() EventType

+ func (e *Event) GetJsonData(data any) error

+ func (e *Event) GetJsonMetadata(metaData any) error

+ func (e *Event) GetMetadata() []byte

+ func (e *Event) GetTimestamp() time.Time

+ func (e *Event) GetVersion() uint64

+ func (e *Event) SetMetadata(metaData any) error

+ func (e *Event) String() string

+ type EventType string

Dec 20, 2023

Changes in this version

+ type HandlerFunc func(context.Context, *Message) error

Dec 18, 2023

Changes in this version

type Client

+ func (k *Client) PublishWithTracer(ctx context.Context, topic string, msg any) error

type IClient

+ PublishWithTracer func(ctx context.Context, topic string, msg any) error

Dec 17, 2023

Changes in this version

+ func RandStringBytes(n int) string

+ type Client struct

+ Backoff backoff.BackOff

+ func NewKafkaClient(cfg *common_utils.BaseConfig) *Client

+ func (k *Client) Close() error

+ func (k *Client) CreateTopic(topic string, numPart int) error

+ func (k *Client) IsReaderConnected() bool

+ func (k *Client) IsWriters() bool

+ func (k *Client) ListTopics() []kafka.Topic

+ func (k *Client) Listen(ctx context.Context, handler KafkaHandler) error

+ func (k *Client) NewConsumer()

+ func (k *Client) NewPublisher() error

+ func (k *Client) Publish(ctx context.Context, topic string, msg any) error

+ type IClient interface

+ Close func() error

+ IsReaderConnected func() bool

+ IsWriters func() bool

+ Listen func(ctx context.Context, handler KafkaHandler) error

+ NewConsumer func()

+ NewPublisher func() error

+ Publish func(ctx context.Context, topic string, msg any) error

+ type KafkaHandler interface

+ Process func(context.Context, *Message) error

+ type Message struct

+ Body []byte

+ Commit func()

+ ConsumerGroup string

+ Headers map[string]string

+ Key string

+ MoveToDLQ func()

+ Offset int64

+ Partition int

+ Timestamp int64

+ Topic string