kafka_mq_proto

type Marker struct {

	// The verison of the marker message
	Version Marker_Version `protobuf:"varint,1,opt,name=version,proto3,enum=Marker_Version" json:"version,omitempty"`
	// The type of marker message
	Type Marker_Type `protobuf:"varint,2,opt,name=type,proto3,enum=Marker_Type" json:"type,omitempty"`
	// The identity of the message that this marker tracks
	MessageId *MessageID `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The number of milliseconds after seeing this marker which will trigger redelivery.
	// Start and KeepAlive markers must have this value set.
	// End markers will not have this value set.
	RedeliverAfterMs uint64 `protobuf:"varint,4,opt,name=redeliver_after_ms,json=redeliverAfterMs,proto3" json:"redeliver_after_ms,omitempty"`
	// The payload of the original record.
	// Start markers must contain non-null payload
	// End and KeepAlive markers will contain null payload
	Key   []byte `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Marker_Type int32

type Marker_Version int32

type MessageID struct {
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}