delete

type MessageRequest struct {
	Topic       string `json:"topic"          form:"topic"        binding:"required"`     //topic name
	Brokers     string `json:"brokers"        form:"brokers"      binding:"required"`     //kafka brokers
	EndOffset   int64  `json:"end_offset"     form:"end_offset"   binding:"exists,min=1"` //end offset, whose offset is smaller than the given offset of the corresponding partition will be delete.
	PartitionID int    `json:"partition_id"   form:"partition_id" binding:"exists,min=0"` //partition id
}

type MessageResponse struct {
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
}

type TopicRequest struct {
	Topic   string `json:"topic"          form:"topic"    binding:"required"` //topic name
	Brokers string `json:"brokers"        form:"brokers"  binding:"required"` //kafka brokers
}

type TopicResponse struct {
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
}