kafka

package

v1.0.1000 Latest Latest Go to latest Published: Aug 22, 2023 License: MIT Imports: 26 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

func NewKafka(tag string, tracing tracing.Tracing, lo logger.Logger, config database.KafkaProviderConfig) database.Kafka

type Kafka struct {
}

func (c *Kafka) Consumer(options database.KafkaOptions, callback database.ConsumerCallback)

func (c *Kafka) Producer(isReady database.ProducerIsReady)

func (c *Kafka) Push(ctx context.Context, id string, options database.KafkaOptions, body interface{}, cb database.ConsumerCallback) error