delete

Documentation

Index

• func Message(ctx *gin.Context)
• func Topic(ctx *gin.Context)
• type MessageRequest
• type MessageResponse
• type TopicRequest
• type TopicResponse

Functions

func Message

func Message(ctx *gin.Context)

Message delete kafka partition messages

func Topic

func Topic(ctx *gin.Context)

Topic delete kafka topic

Types

type MessageRequest

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
}

MessageRequest delete message request

type MessageResponse

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

MessageResponse delete message response

type TopicRequest

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

TopicRequest request

type TopicResponse

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

TopicResponse response