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
src/kpro_records.erl
%% generated code, do not edit!
-module(kpro_records).
-export([fields/1]).
-include("kpro.hrl").
fields(kpro_Packet) ->
record_info(fields, kpro_Packet);
fields(kpro_Request) ->
record_info(fields, kpro_Request);
fields(kpro_Response) ->
record_info(fields, kpro_Response);
fields(kpro_Message) ->
record_info(fields, kpro_Message);
fields(kpro_MetadataRequest) ->
record_info(fields, kpro_MetadataRequest);
fields(kpro_MetadataResponse) ->
record_info(fields, kpro_MetadataResponse);
fields(kpro_Broker) ->
record_info(fields, kpro_Broker);
fields(kpro_TopicMetadata) ->
record_info(fields, kpro_TopicMetadata);
fields(kpro_PartitionMetadata) ->
record_info(fields, kpro_PartitionMetadata);
fields(kpro_ProduceRequest) ->
record_info(fields, kpro_ProduceRequest);
fields(kpro_TopicMessageSet) ->
record_info(fields, kpro_TopicMessageSet);
fields(kpro_PartitionMessageSet) ->
record_info(fields, kpro_PartitionMessageSet);
fields(kpro_ProduceResponse) ->
record_info(fields, kpro_ProduceResponse);
fields(kpro_ProduceResponseTopic) ->
record_info(fields, kpro_ProduceResponseTopic);
fields(kpro_ProduceResponsePartition) ->
record_info(fields, kpro_ProduceResponsePartition);
fields(kpro_FetchRequest) ->
record_info(fields, kpro_FetchRequest);
fields(kpro_FetchRequestTopic) ->
record_info(fields, kpro_FetchRequestTopic);
fields(kpro_FetchRequestPartition) ->
record_info(fields, kpro_FetchRequestPartition);
fields(kpro_FetchResponse) ->
record_info(fields, kpro_FetchResponse);
fields(kpro_FetchResponseTopic) ->
record_info(fields, kpro_FetchResponseTopic);
fields(kpro_FetchResponsePartition) ->
record_info(fields, kpro_FetchResponsePartition);
fields(kpro_OffsetRequest) ->
record_info(fields, kpro_OffsetRequest);
fields(kpro_OffsetRequestTopic) ->
record_info(fields, kpro_OffsetRequestTopic);
fields(kpro_OffsetRequestPartition) ->
record_info(fields, kpro_OffsetRequestPartition);
fields(kpro_OffsetResponse) ->
record_info(fields, kpro_OffsetResponse);
fields(kpro_TopicOffsets) ->
record_info(fields, kpro_TopicOffsets);
fields(kpro_PartitionOffsets) ->
record_info(fields, kpro_PartitionOffsets);
fields(kpro_GroupCoordinatorRequest) ->
record_info(fields, kpro_GroupCoordinatorRequest);
fields(kpro_GroupCoordinatorResponse) ->
record_info(fields, kpro_GroupCoordinatorResponse);
fields(kpro_OffsetCommitRequestV0) ->
record_info(fields, kpro_OffsetCommitRequestV0);
fields(kpro_OCReqV0Topic) ->
record_info(fields, kpro_OCReqV0Topic);
fields(kpro_OCReqV0Partition) ->
record_info(fields, kpro_OCReqV0Partition);
fields(kpro_OffsetCommitRequestV1) ->
record_info(fields, kpro_OffsetCommitRequestV1);
fields(kpro_OCReqV1Topic) ->
record_info(fields, kpro_OCReqV1Topic);
fields(kpro_OCReqV1Partition) ->
record_info(fields, kpro_OCReqV1Partition);
fields(kpro_OffsetCommitRequestV2) ->
record_info(fields, kpro_OffsetCommitRequestV2);
fields(kpro_OCReqV2Topic) ->
record_info(fields, kpro_OCReqV2Topic);
fields(kpro_OCReqV2Partition) ->
record_info(fields, kpro_OCReqV2Partition);
fields(kpro_OffsetCommitResponse) ->
record_info(fields, kpro_OffsetCommitResponse);
fields(kpro_OCRspTopic) ->
record_info(fields, kpro_OCRspTopic);
fields(kpro_OCRspPartition) ->
record_info(fields, kpro_OCRspPartition);
fields(kpro_OffsetFetchRequest) ->
record_info(fields, kpro_OffsetFetchRequest);
fields(kpro_OFReqTopic) ->
record_info(fields, kpro_OFReqTopic);
fields(kpro_OffsetFetchResponse) ->
record_info(fields, kpro_OffsetFetchResponse);
fields(kpro_TopicOffset) ->
record_info(fields, kpro_TopicOffset);
fields(kpro_PartitionOffset) ->
record_info(fields, kpro_PartitionOffset);
fields(kpro_JoinGroupRequest) ->
record_info(fields, kpro_JoinGroupRequest);
fields(kpro_GroupProtocol) ->
record_info(fields, kpro_GroupProtocol);
fields(kpro_JoinGroupResponse) ->
record_info(fields, kpro_JoinGroupResponse);
fields(kpro_GroupMemberMetadata) ->
record_info(fields, kpro_GroupMemberMetadata);
fields(kpro_ConsumerGroupProtocolMetadata) ->
record_info(fields, kpro_ConsumerGroupProtocolMetadata);
fields(kpro_SyncGroupRequest) ->
record_info(fields, kpro_SyncGroupRequest);
fields(kpro_GroupAssignment) ->
record_info(fields, kpro_GroupAssignment);
fields(kpro_ConsumerGroupMemberAssignment) ->
record_info(fields, kpro_ConsumerGroupMemberAssignment);
fields(kpro_ConsumerGroupPartitionAssignment) ->
record_info(fields, kpro_ConsumerGroupPartitionAssignment);
fields(kpro_SyncGroupResponse) ->
record_info(fields, kpro_SyncGroupResponse);
fields(kpro_HeartbeatRequest) ->
record_info(fields, kpro_HeartbeatRequest);
fields(kpro_HeartbeatResponse) ->
record_info(fields, kpro_HeartbeatResponse);
fields(kpro_LeaveGroupRequest) ->
record_info(fields, kpro_LeaveGroupRequest);
fields(kpro_LeaveGroupResponse) ->
record_info(fields, kpro_LeaveGroupResponse);
fields(kpro_ListGroupsRequest) ->
record_info(fields, kpro_ListGroupsRequest);
fields(kpro_ListGroupsResponse) ->
record_info(fields, kpro_ListGroupsResponse);
fields(kpro_GroupInfo) ->
record_info(fields, kpro_GroupInfo);
fields(kpro_DescribeGroupsRequest) ->
record_info(fields, kpro_DescribeGroupsRequest);
fields(kpro_DescribeGroupsResponse) ->
record_info(fields, kpro_DescribeGroupsResponse);
fields(kpro_GroupDescription) ->
record_info(fields, kpro_GroupDescription);
fields(kpro_GroupMemberDescription) ->
record_info(fields, kpro_GroupMemberDescription);
fields(_Unknown) -> false.