Packages
kafka_protocol
0.7.0
4.3.4
4.3.3
4.3.2
4.3.1
4.3.0
4.2.9
4.2.8
4.2.7
4.2.6
4.2.5
4.2.4
4.2.3
4.2.2
4.2.1
4.2.0
4.1.10
4.1.9
4.1.8
4.1.7
4.1.6
4.1.5
4.1.4
4.1.3
4.1.2
4.1.1
4.1.0
4.0.3
4.0.2
4.0.1
3.0.1
3.0.0
2.4.1
2.3.6
2.3.5
2.3.4
2.3.3
2.3.2
2.3.1
2.3.0
2.2.9
2.2.8
2.2.7
2.2.6
2.2.5
2.2.4
2.2.3
2.2.2
2.2.1
2.2.0
2.1.2
2.1.1
2.1.0
2.0.1
2.0.0
1.1.3
1.1.2
1.1.1
1.1.0
1.0.0
0.9.2
0.9.1
0.9.0
0.8.0
0.7.8
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.0
0.4.0
0.3.2
0.3.1
0.2.3
Kafka protocol library for Erlang/Elixir
Current section
Files
Jump to
Current section
Files
include/kpro.hrl
%% 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.