func (*GetTopicMetadataRq) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{11}
}
Deprecated: Use GetTopicMetadataRq.ProtoReflect.Descriptor instead.
package golang
import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
)
const (
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type RecordHeader struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}
func (x *RecordHeader) Reset() {
	*x = RecordHeader{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[0]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *RecordHeader) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*RecordHeader) ProtoMessage() {}
func (x *RecordHeader) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[0]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*RecordHeader) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{0}
}
func (x *RecordHeader) GetKey() string {
	if x != nil {
		return x.Key
	}
	return ""
}
func (x *RecordHeader) GetValue() []byte {
	if x != nil {
		return x.Value
	}
	return nil
}
type ProdRq struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	KeyValue []byte `protobuf:"bytes,3,opt,name=key_value,json=keyValue,proto3" json:"key_value,omitempty"`
	KeyUndefined bool `protobuf:"varint,4,opt,name=key_undefined,json=keyUndefined,proto3" json:"key_undefined,omitempty"`
	Message []byte `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	AsyncMode bool `protobuf:"varint,6,opt,name=async_mode,json=asyncMode,proto3" json:"async_mode,omitempty"`
	Headers []*RecordHeader `protobuf:"bytes,7,rep,name=headers,proto3" json:"headers,omitempty"`
}
func (x *ProdRq) Reset() {
	*x = ProdRq{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[1]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *ProdRq) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*ProdRq) ProtoMessage() {}
func (x *ProdRq) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[1]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*ProdRq) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{1}
}
func (x *ProdRq) GetCluster() string {
	if x != nil {
		return x.Cluster
	}
	return ""
}
func (x *ProdRq) GetTopic() string {
	if x != nil {
		return x.Topic
	}
	return ""
}
func (x *ProdRq) GetKeyValue() []byte {
	if x != nil {
		return x.KeyValue
	}
	return nil
}
func (x *ProdRq) GetKeyUndefined() bool {
	if x != nil {
		return x.KeyUndefined
	}
	return false
}
func (x *ProdRq) GetMessage() []byte {
	if x != nil {
		return x.Message
	}
	return nil
}
func (x *ProdRq) GetAsyncMode() bool {
	if x != nil {
		return x.AsyncMode
	}
	return false
}
func (x *ProdRq) GetHeaders() []*RecordHeader {
	if x != nil {
		return x.Headers
	}
	return nil
}
type ProdRs struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
}
func (x *ProdRs) Reset() {
	*x = ProdRs{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[2]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *ProdRs) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*ProdRs) ProtoMessage() {}
func (x *ProdRs) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[2]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*ProdRs) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{2}
}
func (x *ProdRs) GetPartition() int32 {
	if x != nil {
		return x.Partition
	}
	return 0
}
func (x *ProdRs) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}
type ConsNAckRq struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	NoAck bool `protobuf:"varint,4,opt,name=no_ack,json=noAck,proto3" json:"no_ack,omitempty"`
	AutoAck bool `protobuf:"varint,5,opt,name=auto_ack,json=autoAck,proto3" json:"auto_ack,omitempty"`
	AckPartition int32 `protobuf:"varint,6,opt,name=ack_partition,json=ackPartition,proto3" json:"ack_partition,omitempty"`
	AckOffset    int64 `protobuf:"varint,7,opt,name=ack_offset,json=ackOffset,proto3" json:"ack_offset,omitempty"`
}
func (x *ConsNAckRq) Reset() {
	*x = ConsNAckRq{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[3]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *ConsNAckRq) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*ConsNAckRq) ProtoMessage() {}
func (x *ConsNAckRq) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[3]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*ConsNAckRq) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{3}
}
func (x *ConsNAckRq) GetCluster() string {
	if x != nil {
		return x.Cluster
	}
	return ""
}
func (x *ConsNAckRq) GetTopic() string {
	if x != nil {
		return x.Topic
	}
	return ""
}
func (x *ConsNAckRq) GetGroup() string {
	if x != nil {
		return x.Group
	}
	return ""
}
func (x *ConsNAckRq) GetNoAck() bool {
	if x != nil {
		return x.NoAck
	}
	return false
}
func (x *ConsNAckRq) GetAutoAck() bool {
	if x != nil {
		return x.AutoAck
	}
	return false
}
func (x *ConsNAckRq) GetAckPartition() int32 {
	if x != nil {
		return x.AckPartition
	}
	return 0
}
func (x *ConsNAckRq) GetAckOffset() int64 {
	if x != nil {
		return x.AckOffset
	}
	return 0
}
type ConsRs struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	KeyValue []byte `protobuf:"bytes,3,opt,name=key_value,json=keyValue,proto3" json:"key_value,omitempty"`
	KeyUndefined bool `protobuf:"varint,4,opt,name=key_undefined,json=keyUndefined,proto3" json:"key_undefined,omitempty"`
	Message []byte `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Headers []*RecordHeader `protobuf:"bytes,6,rep,name=headers,proto3" json:"headers,omitempty"`
}
func (x *ConsRs) Reset() {
	*x = ConsRs{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[4]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *ConsRs) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*ConsRs) ProtoMessage() {}
func (x *ConsRs) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[4]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*ConsRs) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{4}
}
func (x *ConsRs) GetPartition() int32 {
	if x != nil {
		return x.Partition
	}
	return 0
}
func (x *ConsRs) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}
func (x *ConsRs) GetKeyValue() []byte {
	if x != nil {
		return x.KeyValue
	}
	return nil
}
func (x *ConsRs) GetKeyUndefined() bool {
	if x != nil {
		return x.KeyUndefined
	}
	return false
}
func (x *ConsRs) GetMessage() []byte {
	if x != nil {
		return x.Message
	}
	return nil
}
func (x *ConsRs) GetHeaders() []*RecordHeader {
	if x != nil {
		return x.Headers
	}
	return nil
}
type AckRq struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Partition int32 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
}
func (x *AckRq) Reset() {
	*x = AckRq{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[5]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *AckRq) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*AckRq) ProtoMessage() {}
func (x *AckRq) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[5]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*AckRq) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{5}
}
func (x *AckRq) GetCluster() string {
	if x != nil {
		return x.Cluster
	}
	return ""
}
func (x *AckRq) GetTopic() string {
	if x != nil {
		return x.Topic
	}
	return ""
}
func (x *AckRq) GetGroup() string {
	if x != nil {
		return x.Group
	}
	return ""
}
func (x *AckRq) GetPartition() int32 {
	if x != nil {
		return x.Partition
	}
	return 0
}
func (x *AckRq) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}
type AckRs struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *AckRs) Reset() {
	*x = AckRs{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[6]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *AckRs) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*AckRs) ProtoMessage() {}
func (x *AckRs) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[6]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*AckRs) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{6}
}
type PartitionOffset struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Begin int64 `protobuf:"varint,2,opt,name=begin,proto3" json:"begin,omitempty"`
	End int64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Lag int64 `protobuf:"varint,6,opt,name=lag,proto3" json:"lag,omitempty"`
	Metadata string `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	SparseAcks string `protobuf:"bytes,8,opt,name=sparse_acks,json=sparseAcks,proto3" json:"sparse_acks,omitempty"`
}
func (x *PartitionOffset) Reset() {
	*x = PartitionOffset{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[7]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *PartitionOffset) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*PartitionOffset) ProtoMessage() {}
func (x *PartitionOffset) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[7]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*PartitionOffset) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{7}
}
func (x *PartitionOffset) GetPartition() int32 {
	if x != nil {
		return x.Partition
	}
	return 0
}
func (x *PartitionOffset) GetBegin() int64 {
	if x != nil {
		return x.Begin
	}
	return 0
}
func (x *PartitionOffset) GetEnd() int64 {
	if x != nil {
		return x.End
	}
	return 0
}
func (x *PartitionOffset) GetCount() int64 {
	if x != nil {
		return x.Count
	}
	return 0
}
func (x *PartitionOffset) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}
func (x *PartitionOffset) GetLag() int64 {
	if x != nil {
		return x.Lag
	}
	return 0
}
func (x *PartitionOffset) GetMetadata() string {
	if x != nil {
		return x.Metadata
	}
	return ""
}
func (x *PartitionOffset) GetSparseAcks() string {
	if x != nil {
		return x.SparseAcks
	}
	return ""
}
type GetOffsetsRq struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
}
func (x *GetOffsetsRq) Reset() {
	*x = GetOffsetsRq{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[8]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *GetOffsetsRq) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*GetOffsetsRq) ProtoMessage() {}
func (x *GetOffsetsRq) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[8]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*GetOffsetsRq) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{8}
}
func (x *GetOffsetsRq) GetCluster() string {
	if x != nil {
		return x.Cluster
	}
	return ""
}
func (x *GetOffsetsRq) GetTopic() string {
	if x != nil {
		return x.Topic
	}
	return ""
}
func (x *GetOffsetsRq) GetGroup() string {
	if x != nil {
		return x.Group
	}
	return ""
}
type GetOffsetsRs struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Offsets []*PartitionOffset `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty"`
}
func (x *GetOffsetsRs) Reset() {
	*x = GetOffsetsRs{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[9]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *GetOffsetsRs) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*GetOffsetsRs) ProtoMessage() {}
func (x *GetOffsetsRs) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[9]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*GetOffsetsRs) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{9}
}
func (x *GetOffsetsRs) GetOffsets() []*PartitionOffset {
	if x != nil {
		return x.Offsets
	}
	return nil
}
type PartitionMetadata struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Leader int32 `protobuf:"varint,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Replicas []int32 `protobuf:"varint,3,rep,packed,name=replicas,proto3" json:"replicas,omitempty"`
	Isr []int32 `protobuf:"varint,4,rep,packed,name=isr,proto3" json:"isr,omitempty"`
}
func (x *PartitionMetadata) Reset() {
	*x = PartitionMetadata{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[10]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *PartitionMetadata) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*PartitionMetadata) ProtoMessage() {}
func (x *PartitionMetadata) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[10]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*PartitionMetadata) Descriptor() ([]byte, []int) {
	return file_kafkapixy_proto_rawDescGZIP(), []int{10}
}
func (x *PartitionMetadata) GetPartition() int32 {
	if x != nil {
		return x.Partition
	}
	return 0
}
func (x *PartitionMetadata) GetLeader() int32 {
	if x != nil {
		return x.Leader
	}
	return 0
}
func (x *PartitionMetadata) GetReplicas() []int32 {
	if x != nil {
		return x.Replicas
	}
	return nil
}
func (x *PartitionMetadata) GetIsr() []int32 {
	if x != nil {
		return x.Isr
	}
	return nil
}
type GetTopicMetadataRq struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WithPartitions bool `protobuf:"varint,3,opt,name=with_partitions,json=withPartitions,proto3" json:"with_partitions,omitempty"`
}
func (x *GetTopicMetadataRq) Reset() {
	*x = GetTopicMetadataRq{}
	if protoimpl.UnsafeEnabled {
		mi := &file_kafkapixy_proto_msgTypes[11]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *GetTopicMetadataRq) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*GetTopicMetadataRq) ProtoMessage() {}
func (x *GetTopicMetadataRq) ProtoReflect() protoreflect.Message {
	mi := &file_kafkapixy_proto_msgTypes[11]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}