%% generated code, do not edit! -ifndef(kpro_hrl). -define(kpro_hrl, true). -include("kpro_common.hrl"). -record(kpro_Packet, { size :: kpro:int32() , payload :: kpro_Payload() }). -type kpro_Payload() :: kpro_Request() | kpro_Response(). -record(kpro_Request, { apiKey :: kpro:int16() , apiVersion :: kpro:int16() , correlationId :: kpro:int32() , clientId :: kpro:str() , requestMessage :: kpro_RequestMessage() }). -type kpro_RequestMessage() :: kpro_ProduceRequest() | kpro_FetchRequest() | kpro_OffsetRequest() | kpro_MetadataRequest() | kpro_OffsetCommitRequestV0() | kpro_OffsetCommitRequestV1() | kpro_OffsetCommitRequestV2() | kpro_OffsetFetchRequest() | kpro_GroupCoordinatorRequest() | kpro_JoinGroupRequest() | kpro_HeartbeatRequest() | kpro_LeaveGroupRequest() | kpro_SyncGroupRequest() | kpro_DescribeGroupsRequest() | kpro_ListGroupsRequest(). -record(kpro_Response, { correlationId :: kpro:int32() , responseMessage :: kpro_ResponseMessage() }). -type kpro_ResponseMessage() :: kpro_ProduceResponse() | kpro_FetchResponse() | kpro_OffsetResponse() | kpro_MetadataResponse() | kpro_OffsetCommitResponse() | kpro_OffsetFetchResponse() | kpro_GroupCoordinatorResponse() | kpro_JoinGroupResponse() | kpro_HeartbeatResponse() | kpro_LeaveGroupResponse() | kpro_SyncGroupResponse() | kpro_DescribeGroupsResponse() | kpro_ListGroupsResponse(). -record(kpro_Message, { offset :: kpro:int64() , messageSize :: kpro:int32() , crc :: kpro:int32() , magicByte :: kpro:int8() , attributes :: kpro:int8() , key :: kpro:kafka_key() , value :: kpro:kafka_value() }). -record(kpro_MetadataRequest, { topicName_L :: [kpro:str()] }). -record(kpro_MetadataResponse, { broker_L :: [kpro_Broker()] , topicMetadata_L :: [kpro_TopicMetadata()] }). -record(kpro_Broker, { nodeId :: kpro:int32() , host :: kpro:str() , port :: kpro:int32() }). -record(kpro_TopicMetadata, { errorCode :: kpro:error_code() , topicName :: kpro:str() , partitionMetadata_L :: [kpro_PartitionMetadata()] }). -record(kpro_PartitionMetadata, { errorCode :: kpro:error_code() , partition :: kpro:int32() , leader :: kpro:int32() , replicas :: [kpro:int32()] , isr :: [kpro:int32()] }). -record(kpro_ProduceRequest, { requiredAcks :: kpro:int16() , timeout :: kpro:int32() , topicMessageSet_L :: [kpro_TopicMessageSet()] }). -record(kpro_TopicMessageSet, { topicName :: kpro:str() , partitionMessageSet_L :: [kpro_PartitionMessageSet()] }). -record(kpro_PartitionMessageSet, { partition :: kpro:int32() , messageSetSize :: kpro:int32() , message_L :: [kpro_Message()] }). -record(kpro_ProduceResponse, { produceResponseTopic_L :: [kpro_ProduceResponseTopic()] }). -record(kpro_ProduceResponseTopic, { topicName :: kpro:str() , produceResponsePartition_L :: [kpro_ProduceResponsePartition()] }). -record(kpro_ProduceResponsePartition, { partition :: kpro:int32() , errorCode :: kpro:error_code() , offset :: kpro:int64() }). -record(kpro_FetchRequest, { replicaId :: kpro:int32() , maxWaitTime :: kpro:int32() , minBytes :: kpro:int32() , fetchRequestTopic_L :: [kpro_FetchRequestTopic()] }). -record(kpro_FetchRequestTopic, { topicName :: kpro:str() , fetchRequestPartition_L :: [kpro_FetchRequestPartition()] }). -record(kpro_FetchRequestPartition, { partition :: kpro:int32() , fetchOffset :: kpro:int64() , maxBytes :: kpro:int32() }). -record(kpro_FetchResponse, { fetchResponseTopic_L :: [kpro_FetchResponseTopic()] }). -record(kpro_FetchResponseTopic, { topicName :: kpro:str() , fetchResponsePartition_L :: [kpro_FetchResponsePartition()] }). -record(kpro_FetchResponsePartition, { partition :: kpro:int32() , errorCode :: kpro:error_code() , highWatermarkOffset :: kpro:int64() , messageSetSize :: kpro:int32() , message_L :: [kpro_Message()] }). -record(kpro_OffsetRequest, { replicaId :: kpro:int32() , offsetRequestTopic_L :: [kpro_OffsetRequestTopic()] }). -record(kpro_OffsetRequestTopic, { topicName :: kpro:str() , offsetRequestPartition_L :: [kpro_OffsetRequestPartition()] }). -record(kpro_OffsetRequestPartition, { partition :: kpro:int32() , time :: kpro:int64() , maxNumberOfOffsets :: kpro:int32() }). -record(kpro_OffsetResponse, { topicOffsets_L :: [kpro_TopicOffsets()] }). -record(kpro_TopicOffsets, { topicName :: kpro:str() , partitionOffsets_L :: [kpro_PartitionOffsets()] }). -record(kpro_PartitionOffsets, { partition :: kpro:int32() , errorCode :: kpro:error_code() , offset_L :: [kpro:int64()] }). -record(kpro_GroupCoordinatorRequest, { groupId :: kpro:str() }). -record(kpro_GroupCoordinatorResponse, { errorCode :: kpro:error_code() , coordinatorId :: kpro:int32() , coordinatorHost :: kpro:str() , coordinatorPort :: kpro:int32() }). -record(kpro_OffsetCommitRequestV0, { consumerGroupId :: kpro:str() , oCReqV0Topic_L :: [kpro_OCReqV0Topic()] }). -record(kpro_OCReqV0Topic, { topicName :: kpro:str() , oCReqV0Partition_L :: [kpro_OCReqV0Partition()] }). -record(kpro_OCReqV0Partition, { partition :: kpro:int32() , offset :: kpro:int64() , metadata :: kpro:str() }). -record(kpro_OffsetCommitRequestV1, { consumerGroupId :: kpro:str() , consumerGroupGenerationId :: kpro:int32() , consumerId :: kpro:str() , oCReqV1Topic_L :: [kpro_OCReqV1Topic()] }). -record(kpro_OCReqV1Topic, { topicName :: kpro:str() , oCReqV1Partition_L :: [kpro_OCReqV1Partition()] }). -record(kpro_OCReqV1Partition, { partition :: kpro:int32() , offset :: kpro:int64() , timeStamp :: kpro:int64() , metadata :: kpro:str() }). -record(kpro_OffsetCommitRequestV2, { consumerGroupId :: kpro:str() , consumerGroupGenerationId :: kpro:int32() , consumerId :: kpro:str() , retentionTime :: kpro:int64() , oCReqV2Topic_L :: [kpro_OCReqV2Topic()] }). -record(kpro_OCReqV2Topic, { topicName :: kpro:str() , oCReqV2Partition_L :: [kpro_OCReqV2Partition()] }). -record(kpro_OCReqV2Partition, { partition :: kpro:int32() , offset :: kpro:int64() , metadata :: kpro:str() }). -record(kpro_OffsetCommitResponse, { oCRspTopic_L :: [kpro_OCRspTopic()] }). -record(kpro_OCRspTopic, { topicName :: kpro:str() , oCRspPartition_L :: [kpro_OCRspPartition()] }). -record(kpro_OCRspPartition, { partition :: kpro:int32() , errorCode :: kpro:error_code() }). -record(kpro_OffsetFetchRequest, { consumerGroup :: kpro:str() , oFReqTopic_L :: [kpro_OFReqTopic()] }). -record(kpro_OFReqTopic, { topicName :: kpro:str() , partition_L :: [kpro:int32()] }). -record(kpro_OffsetFetchResponse, { topicOffset_L :: [kpro_TopicOffset()] }). -record(kpro_TopicOffset, { topicName :: kpro:str() , partitionOffset_L :: [kpro_PartitionOffset()] }). -record(kpro_PartitionOffset, { partition :: kpro:int32() , offset :: kpro:int64() , metadata :: kpro:str() , errorCode :: kpro:error_code() }). -record(kpro_JoinGroupRequest, { groupId :: kpro:str() , sessionTimeout :: kpro:int32() , memberId :: kpro:str() , protocolType :: kpro:str() , groupProtocol_L :: [kpro_GroupProtocol()] }). -record(kpro_GroupProtocol, { protocolName :: kpro:str() , protocolMetadata :: any() }). -record(kpro_JoinGroupResponse, { errorCode :: kpro:error_code() , generationId :: kpro:int32() , protocolName :: kpro:str() , leaderId :: kpro:str() , memberId :: kpro:str() , groupMemberMetadata_L :: [kpro_GroupMemberMetadata()] }). -record(kpro_GroupMemberMetadata, { memberId :: kpro:str() , protocolMetadata :: any() }). -record(kpro_ConsumerGroupProtocolMetadata, { version :: kpro:int16() , topicName_L :: [kpro:str()] , userData :: binary() }). -record(kpro_SyncGroupRequest, { groupId :: kpro:str() , generationId :: kpro:int32() , memberId :: kpro:str() , groupAssignment_L :: [kpro_GroupAssignment()] }). -record(kpro_GroupAssignment, { memberId :: kpro:str() , memberAssignment :: any() }). -record(kpro_ConsumerGroupMemberAssignment, { version :: kpro:int16() , consumerGroupPartitionAssignment_L :: [kpro_ConsumerGroupPartitionAssignment()] , userData :: binary() }). -record(kpro_ConsumerGroupPartitionAssignment, { topicName :: kpro:str() , partition_L :: [kpro:int32()] }). -record(kpro_SyncGroupResponse, { errorCode :: kpro:error_code() , memberAssignment :: any() }). -record(kpro_HeartbeatRequest, { groupId :: kpro:str() , generationId :: kpro:int32() , memberId :: kpro:str() }). -record(kpro_HeartbeatResponse, { errorCode :: kpro:error_code() }). -record(kpro_LeaveGroupRequest, { groupId :: kpro:str() , memberId :: kpro:str() }). -record(kpro_LeaveGroupResponse, { errorCode :: kpro:error_code() }). -record(kpro_ListGroupsRequest, { }). -record(kpro_ListGroupsResponse, { errorCode :: kpro:error_code() , groupInfo_L :: [kpro_GroupInfo()] }). -record(kpro_GroupInfo, { groupId :: kpro:str() , protocolType :: kpro:str() }). -record(kpro_DescribeGroupsRequest, { groupId_L :: [kpro:str()] }). -record(kpro_DescribeGroupsResponse, { groupDescription_L :: [kpro_GroupDescription()] }). -record(kpro_GroupDescription, { errorCode :: kpro:error_code() , groupId :: kpro:str() , state :: kpro:str() , protocolType :: kpro:str() , protocol :: kpro:str() , groupMemberDescription_L :: [kpro_GroupMemberDescription()] }). -record(kpro_GroupMemberDescription, { memberId :: kpro:str() , clientId :: kpro:str() , clientHost :: kpro:str() , memberMetadata :: binary() , memberAssignment :: any() }). -type kpro_Packet() :: #kpro_Packet{}. -type kpro_Request() :: #kpro_Request{}. -type kpro_Response() :: #kpro_Response{}. -type kpro_Message() :: incomplete_message | #kpro_Message{}. -type kpro_MetadataRequest() :: #kpro_MetadataRequest{}. -type kpro_MetadataResponse() :: #kpro_MetadataResponse{}. -type kpro_Broker() :: #kpro_Broker{}. -type kpro_TopicMetadata() :: #kpro_TopicMetadata{}. -type kpro_PartitionMetadata() :: #kpro_PartitionMetadata{}. -type kpro_ProduceRequest() :: #kpro_ProduceRequest{}. -type kpro_TopicMessageSet() :: #kpro_TopicMessageSet{}. -type kpro_PartitionMessageSet() :: #kpro_PartitionMessageSet{}. -type kpro_ProduceResponse() :: #kpro_ProduceResponse{}. -type kpro_ProduceResponseTopic() :: #kpro_ProduceResponseTopic{}. -type kpro_ProduceResponsePartition() :: #kpro_ProduceResponsePartition{}. -type kpro_FetchRequest() :: #kpro_FetchRequest{}. -type kpro_FetchRequestTopic() :: #kpro_FetchRequestTopic{}. -type kpro_FetchRequestPartition() :: #kpro_FetchRequestPartition{}. -type kpro_FetchResponse() :: #kpro_FetchResponse{}. -type kpro_FetchResponseTopic() :: #kpro_FetchResponseTopic{}. -type kpro_FetchResponsePartition() :: #kpro_FetchResponsePartition{}. -type kpro_OffsetRequest() :: #kpro_OffsetRequest{}. -type kpro_OffsetRequestTopic() :: #kpro_OffsetRequestTopic{}. -type kpro_OffsetRequestPartition() :: #kpro_OffsetRequestPartition{}. -type kpro_OffsetResponse() :: #kpro_OffsetResponse{}. -type kpro_TopicOffsets() :: #kpro_TopicOffsets{}. -type kpro_PartitionOffsets() :: #kpro_PartitionOffsets{}. -type kpro_GroupCoordinatorRequest() :: #kpro_GroupCoordinatorRequest{}. -type kpro_GroupCoordinatorResponse() :: #kpro_GroupCoordinatorResponse{}. -type kpro_OffsetCommitRequestV0() :: #kpro_OffsetCommitRequestV0{}. -type kpro_OCReqV0Topic() :: #kpro_OCReqV0Topic{}. -type kpro_OCReqV0Partition() :: #kpro_OCReqV0Partition{}. -type kpro_OffsetCommitRequestV1() :: #kpro_OffsetCommitRequestV1{}. -type kpro_OCReqV1Topic() :: #kpro_OCReqV1Topic{}. -type kpro_OCReqV1Partition() :: #kpro_OCReqV1Partition{}. -type kpro_OffsetCommitRequestV2() :: #kpro_OffsetCommitRequestV2{}. -type kpro_OCReqV2Topic() :: #kpro_OCReqV2Topic{}. -type kpro_OCReqV2Partition() :: #kpro_OCReqV2Partition{}. -type kpro_OffsetCommitResponse() :: #kpro_OffsetCommitResponse{}. -type kpro_OCRspTopic() :: #kpro_OCRspTopic{}. -type kpro_OCRspPartition() :: #kpro_OCRspPartition{}. -type kpro_OffsetFetchRequest() :: #kpro_OffsetFetchRequest{}. -type kpro_OFReqTopic() :: #kpro_OFReqTopic{}. -type kpro_OffsetFetchResponse() :: #kpro_OffsetFetchResponse{}. -type kpro_TopicOffset() :: #kpro_TopicOffset{}. -type kpro_PartitionOffset() :: #kpro_PartitionOffset{}. -type kpro_JoinGroupRequest() :: #kpro_JoinGroupRequest{}. -type kpro_GroupProtocol() :: #kpro_GroupProtocol{}. -type kpro_JoinGroupResponse() :: #kpro_JoinGroupResponse{}. -type kpro_GroupMemberMetadata() :: #kpro_GroupMemberMetadata{}. -type kpro_ConsumerGroupProtocolMetadata() :: #kpro_ConsumerGroupProtocolMetadata{}. -type kpro_SyncGroupRequest() :: #kpro_SyncGroupRequest{}. -type kpro_GroupAssignment() :: #kpro_GroupAssignment{}. -type kpro_ConsumerGroupMemberAssignment() :: #kpro_ConsumerGroupMemberAssignment{}. -type kpro_ConsumerGroupPartitionAssignment() :: #kpro_ConsumerGroupPartitionAssignment{}. -type kpro_SyncGroupResponse() :: #kpro_SyncGroupResponse{}. -type kpro_HeartbeatRequest() :: #kpro_HeartbeatRequest{}. -type kpro_HeartbeatResponse() :: #kpro_HeartbeatResponse{}. -type kpro_LeaveGroupRequest() :: #kpro_LeaveGroupRequest{}. -type kpro_LeaveGroupResponse() :: #kpro_LeaveGroupResponse{}. -type kpro_ListGroupsRequest() :: #kpro_ListGroupsRequest{}. -type kpro_ListGroupsResponse() :: #kpro_ListGroupsResponse{}. -type kpro_GroupInfo() :: #kpro_GroupInfo{}. -type kpro_DescribeGroupsRequest() :: #kpro_DescribeGroupsRequest{}. -type kpro_DescribeGroupsResponse() :: #kpro_DescribeGroupsResponse{}. -type kpro_GroupDescription() :: #kpro_GroupDescription{}. -type kpro_GroupMemberDescription() :: #kpro_GroupMemberDescription{}. -endif.