kafkastreamer

package

v0.4.2 Latest Latest Go to latest Published: Dec 30, 2023 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	// contains filtered or unexported fields
}

func (c *Consumer) Close() error

func (c *Consumer) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)

type Producer struct {
	Topic         string
	Writer        *kafka.Writer
	WriterTimeout time.Duration
}

func (p *Producer) Close() error

func (p *Producer) Send(ctx context.Context, recordID int64, statusType int, headers map[workflow.Header]string) error

type StreamConstructor struct {
	// contains filtered or unexported fields
}

func New(brokers []string) *StreamConstructor

func (s StreamConstructor) NewConsumer(topic string, name string, opts ...workflow.ConsumerOption) workflow.Consumer

func (s StreamConstructor) NewProducer(topic string) workflow.Producer