kafka

Aug 16, 2024

Changes in this version

+ func FeatureLogToKafka(kafkaName string, f FeatureLogKafkaFunc)

+ func Load(config *recconf.RecommendConfig)

+ type FeatureLogKafkaFunc func(*KafkaProducer, *module.User, []*module.Item, *context.RecommendContext)

+ type KafkaLog struct

+ func (l *KafkaLog) Errorf(msg string, args ...interface{})

+ type KafkaProducer struct

+ BootstrapServers string

+ Producer *kafka.Writer

+ Topic string

+ func GetKafkaProducer(name string) (*KafkaProducer, error)

+ func NewKafkaProducer(bootstrapServers, topic string) *KafkaProducer

+ func (k *KafkaProducer) Close()

+ func (k *KafkaProducer) Init() error

+ func (k *KafkaProducer) SendMessage(message []byte)

+ func (k *KafkaProducer) SendMessages(module []byte, message []byte)