broker

Documentation

Index

• Constants
• func Create(producer *confluentKafka.Producer, data common.VideoConvertData) error
• func Subscribe(consumer *confluentKafka.Consumer, repos *repository.Repository)
• type Kafka
  • func NewKafka() (*Kafka, error)

Constants

const GROUP_ID = "myGroup"

Functions

func Create

func Create(producer *confluentKafka.Producer, data common.VideoConvertData) error

func Subscribe

func Subscribe(consumer *confluentKafka.Consumer, repos *repository.Repository)

Types

type Kafka

type Kafka struct {
	Consumer *kafka.Consumer
	Producer *kafka.Producer
}

func NewKafka

func NewKafka() (*Kafka, error)