consumer

type MessagesRequest struct {
	Topic         string `json:"topic"          form:"topic"   binding:"required"` //consumer topic name
	Brokers       string `json:"brokers"        form:"brokers" binding:"required"` //kafka brokers
	ConsumerGroup string `json:"consumer_group" form:"consumer_group"`             //consumer group name, default generate random name
	Count         int    `json:"count"          form:"count"`                      //message count, range 1~10, default 10
	TimeWait      int    `json:"time_wait"      form:"time_wait"`                  //time wait 2 consumer message, range 1~60 second, default 3 second
}