kafka

Documentation

Index

• func Consume(c kq.KqConf, consumerName string, handler kq.ConsumeHandler)
• func DelaySetUp(redis *redis.Redis, batchSize int, prefix string)
• func NewProducer(topic string, opts ...kq.PushOption) (*kq.Pusher, error)
• func Push(ctx context.Context, topic string, data any, sync ...bool) error
• func PushDelay(ctx context.Context, topic string, data any, delayDuration time.Duration) error

Functions

func Consume

func Consume(c kq.KqConf, consumerName string, handler kq.ConsumeHandler)

func DelaySetUp

func DelaySetUp(redis *redis.Redis, batchSize int, prefix string)

func NewProducer

func NewProducer(topic string, opts ...kq.PushOption) (*kq.Pusher, error)

func Push

func Push(ctx context.Context, topic string, data any, sync ...bool) error

func PushDelay

func PushDelay(ctx context.Context, topic string, data any, delayDuration time.Duration) error