consumer

Documentation

Index

• Constants
• Variables
• func RunBookingStatusConsumer()

Constants

const (
	BOOKING_STATUS_CG    = "momo-q1c28"
	BOOKING_STATUS_TOPIC = "meeting_status_channel"
)

Variables

var KafkaChan = make(chan string)

用 channel

Functions

func RunBookingStatusConsumer

func RunBookingStatusConsumer()

消费activation-affiliate topic, 入库