kafka

package
v0.0.0-...-2c5f5e2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue

type Queue struct {
	Kafka     *kafka.Entity
	EventChan chan *event.Entity
	ErrorChan chan error
}

func (*Queue) Consume

func (q *Queue) Consume(ctx context.Context) error

* 仅支持以 consumer group 的方式获取kafka的数据

func (*Queue) ConsumeWithHandler

func (q *Queue) ConsumeWithHandler(ctx context.Context, handler abstract.ConsumeHandler) error

func (*Queue) Errors

func (q *Queue) Errors() chan error

func (*Queue) Events

func (q *Queue) Events() chan *event.Entity

func (*Queue) SyncProduce

func (q *Queue) SyncProduce(_ context.Context, event *event.Entity) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL