Packages
kafka_protocol
0.9.2
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.bak
%% generated code, do not edit!
-module(kpro_records).
-export([fields/1]).
-include("kpro.hrl").
fields(kpro_packet) ->
record_info(fields, kpro_packet);
fields(kpro_message) ->
record_info(fields, kpro_message);
fields(kpro_consumer_group_protocol_metadata) ->
record_info(fields, kpro_consumer_group_protocol_metadata);
fields(kpro_consumer_group_member_assignment) ->
record_info(fields, kpro_consumer_group_member_assignment);
fields(kpro_consumer_group_member_assignment_partition_assignment) ->
record_info(fields, kpro_consumer_group_member_assignment_partition_assignment);
fields(kpro_request) ->
record_info(fields, kpro_request);
fields(kpro_request_header) ->
record_info(fields, kpro_request_header);
fields(kpro_response) ->
record_info(fields, kpro_response);
fields(kpro_response_header) ->
record_info(fields, kpro_response_header);
fields(kpro_produce_request_v0) ->
record_info(fields, kpro_produce_request_v0);
fields(kpro_produce_request_v0_topic_data) ->
record_info(fields, kpro_produce_request_v0_topic_data);
fields(kpro_produce_request_v0_data) ->
record_info(fields, kpro_produce_request_v0_data);
fields(kpro_produce_request_v1) ->
record_info(fields, kpro_produce_request_v1);
fields(kpro_produce_request_v1_topic_data) ->
record_info(fields, kpro_produce_request_v1_topic_data);
fields(kpro_produce_request_v1_data) ->
record_info(fields, kpro_produce_request_v1_data);
fields(kpro_produce_request_v2) ->
record_info(fields, kpro_produce_request_v2);
fields(kpro_produce_request_v2_topic_data) ->
record_info(fields, kpro_produce_request_v2_topic_data);
fields(kpro_produce_request_v2_data) ->
record_info(fields, kpro_produce_request_v2_data);
fields(kpro_produce_response_v0) ->
record_info(fields, kpro_produce_response_v0);
fields(kpro_produce_response_v0_response) ->
record_info(fields, kpro_produce_response_v0_response);
fields(kpro_produce_response_v0_partition_response) ->
record_info(fields, kpro_produce_response_v0_partition_response);
fields(kpro_produce_response_v1) ->
record_info(fields, kpro_produce_response_v1);
fields(kpro_produce_response_v1_response) ->
record_info(fields, kpro_produce_response_v1_response);
fields(kpro_produce_response_v1_partition_response) ->
record_info(fields, kpro_produce_response_v1_partition_response);
fields(kpro_produce_response_v2) ->
record_info(fields, kpro_produce_response_v2);
fields(kpro_produce_response_v2_response) ->
record_info(fields, kpro_produce_response_v2_response);
fields(kpro_produce_response_v2_partition_response) ->
record_info(fields, kpro_produce_response_v2_partition_response);
fields(kpro_fetch_request_v0) ->
record_info(fields, kpro_fetch_request_v0);
fields(kpro_fetch_request_v0_topic) ->
record_info(fields, kpro_fetch_request_v0_topic);
fields(kpro_fetch_request_v0_partition) ->
record_info(fields, kpro_fetch_request_v0_partition);
fields(kpro_fetch_request_v1) ->
record_info(fields, kpro_fetch_request_v1);
fields(kpro_fetch_request_v1_topic) ->
record_info(fields, kpro_fetch_request_v1_topic);
fields(kpro_fetch_request_v1_partition) ->
record_info(fields, kpro_fetch_request_v1_partition);
fields(kpro_fetch_request_v2) ->
record_info(fields, kpro_fetch_request_v2);
fields(kpro_fetch_request_v2_topic) ->
record_info(fields, kpro_fetch_request_v2_topic);
fields(kpro_fetch_request_v2_partition) ->
record_info(fields, kpro_fetch_request_v2_partition);
fields(kpro_fetch_request_v3) ->
record_info(fields, kpro_fetch_request_v3);
fields(kpro_fetch_request_v3_topic) ->
record_info(fields, kpro_fetch_request_v3_topic);
fields(kpro_fetch_request_v3_partition) ->
record_info(fields, kpro_fetch_request_v3_partition);
fields(kpro_fetch_response_v0) ->
record_info(fields, kpro_fetch_response_v0);
fields(kpro_fetch_response_v0_response) ->
record_info(fields, kpro_fetch_response_v0_response);
fields(kpro_fetch_response_v0_partition_response) ->
record_info(fields, kpro_fetch_response_v0_partition_response);
fields(kpro_fetch_response_v0_partition_header) ->
record_info(fields, kpro_fetch_response_v0_partition_header);
fields(kpro_fetch_response_v1) ->
record_info(fields, kpro_fetch_response_v1);
fields(kpro_fetch_response_v1_response) ->
record_info(fields, kpro_fetch_response_v1_response);
fields(kpro_fetch_response_v1_partition_response) ->
record_info(fields, kpro_fetch_response_v1_partition_response);
fields(kpro_fetch_response_v1_partition_header) ->
record_info(fields, kpro_fetch_response_v1_partition_header);
fields(kpro_fetch_response_v2) ->
record_info(fields, kpro_fetch_response_v2);
fields(kpro_fetch_response_v2_response) ->
record_info(fields, kpro_fetch_response_v2_response);
fields(kpro_fetch_response_v2_partition_response) ->
record_info(fields, kpro_fetch_response_v2_partition_response);
fields(kpro_fetch_response_v2_partition_header) ->
record_info(fields, kpro_fetch_response_v2_partition_header);
fields(kpro_fetch_response_v3) ->
record_info(fields, kpro_fetch_response_v3);
fields(kpro_fetch_response_v3_response) ->
record_info(fields, kpro_fetch_response_v3_response);
fields(kpro_fetch_response_v3_partition_response) ->
record_info(fields, kpro_fetch_response_v3_partition_response);
fields(kpro_fetch_response_v3_partition_header) ->
record_info(fields, kpro_fetch_response_v3_partition_header);
fields(kpro_offsets_request_v0) ->
record_info(fields, kpro_offsets_request_v0);
fields(kpro_offsets_request_v0_topic) ->
record_info(fields, kpro_offsets_request_v0_topic);
fields(kpro_offsets_request_v0_partition) ->
record_info(fields, kpro_offsets_request_v0_partition);
fields(kpro_offsets_request_v1) ->
record_info(fields, kpro_offsets_request_v1);
fields(kpro_offsets_request_v1_topic) ->
record_info(fields, kpro_offsets_request_v1_topic);
fields(kpro_offsets_request_v1_partition) ->
record_info(fields, kpro_offsets_request_v1_partition);
fields(kpro_offsets_response_v0) ->
record_info(fields, kpro_offsets_response_v0);
fields(kpro_offsets_response_v0_response) ->
record_info(fields, kpro_offsets_response_v0_response);
fields(kpro_offsets_response_v0_partition_response) ->
record_info(fields, kpro_offsets_response_v0_partition_response);
fields(kpro_offsets_response_v1) ->
record_info(fields, kpro_offsets_response_v1);
fields(kpro_offsets_response_v1_response) ->
record_info(fields, kpro_offsets_response_v1_response);
fields(kpro_offsets_response_v1_partition_response) ->
record_info(fields, kpro_offsets_response_v1_partition_response);
fields(kpro_metadata_request_v0) ->
record_info(fields, kpro_metadata_request_v0);
fields(kpro_metadata_request_v1) ->
record_info(fields, kpro_metadata_request_v1);
fields(kpro_metadata_request_v2) ->
record_info(fields, kpro_metadata_request_v2);
fields(kpro_metadata_response_v0) ->
record_info(fields, kpro_metadata_response_v0);
fields(kpro_metadata_response_v0_broker) ->
record_info(fields, kpro_metadata_response_v0_broker);
fields(kpro_metadata_response_v0_topic_metadata) ->
record_info(fields, kpro_metadata_response_v0_topic_metadata);
fields(kpro_metadata_response_v0_partition_metadata) ->
record_info(fields, kpro_metadata_response_v0_partition_metadata);
fields(kpro_metadata_response_v1) ->
record_info(fields, kpro_metadata_response_v1);
fields(kpro_metadata_response_v1_broker) ->
record_info(fields, kpro_metadata_response_v1_broker);
fields(kpro_metadata_response_v1_topic_metadata) ->
record_info(fields, kpro_metadata_response_v1_topic_metadata);
fields(kpro_metadata_response_v1_partition_metadata) ->
record_info(fields, kpro_metadata_response_v1_partition_metadata);
fields(kpro_metadata_response_v2) ->
record_info(fields, kpro_metadata_response_v2);
fields(kpro_metadata_response_v2_broker) ->
record_info(fields, kpro_metadata_response_v2_broker);
fields(kpro_metadata_response_v2_topic_metadata) ->
record_info(fields, kpro_metadata_response_v2_topic_metadata);
fields(kpro_metadata_response_v2_partition_metadata) ->
record_info(fields, kpro_metadata_response_v2_partition_metadata);
fields(kpro_leader_and_isr_request_v0) ->
record_info(fields, kpro_leader_and_isr_request_v0);
fields(kpro_leader_and_isr_request_v0_partition_state) ->
record_info(fields, kpro_leader_and_isr_request_v0_partition_state);
fields(kpro_leader_and_isr_request_v0_live_leader) ->
record_info(fields, kpro_leader_and_isr_request_v0_live_leader);
fields(kpro_leader_and_isr_response_v0) ->
record_info(fields, kpro_leader_and_isr_response_v0);
fields(kpro_leader_and_isr_response_v0_partition) ->
record_info(fields, kpro_leader_and_isr_response_v0_partition);
fields(kpro_stop_replica_request_v0) ->
record_info(fields, kpro_stop_replica_request_v0);
fields(kpro_stop_replica_request_v0_partition) ->
record_info(fields, kpro_stop_replica_request_v0_partition);
fields(kpro_stop_replica_response_v0) ->
record_info(fields, kpro_stop_replica_response_v0);
fields(kpro_stop_replica_response_v0_partition) ->
record_info(fields, kpro_stop_replica_response_v0_partition);
fields(kpro_update_metadata_request_v0) ->
record_info(fields, kpro_update_metadata_request_v0);
fields(kpro_update_metadata_request_v0_partition_state) ->
record_info(fields, kpro_update_metadata_request_v0_partition_state);
fields(kpro_update_metadata_request_v0_live_broker) ->
record_info(fields, kpro_update_metadata_request_v0_live_broker);
fields(kpro_update_metadata_request_v1) ->
record_info(fields, kpro_update_metadata_request_v1);
fields(kpro_update_metadata_request_v1_partition_state) ->
record_info(fields, kpro_update_metadata_request_v1_partition_state);
fields(kpro_update_metadata_request_v1_live_broker) ->
record_info(fields, kpro_update_metadata_request_v1_live_broker);
fields(kpro_update_metadata_request_v1_end_point) ->
record_info(fields, kpro_update_metadata_request_v1_end_point);
fields(kpro_update_metadata_request_v2) ->
record_info(fields, kpro_update_metadata_request_v2);
fields(kpro_update_metadata_request_v2_partition_state) ->
record_info(fields, kpro_update_metadata_request_v2_partition_state);
fields(kpro_update_metadata_request_v2_live_broker) ->
record_info(fields, kpro_update_metadata_request_v2_live_broker);
fields(kpro_update_metadata_request_v2_end_point) ->
record_info(fields, kpro_update_metadata_request_v2_end_point);
fields(kpro_update_metadata_request_v3) ->
record_info(fields, kpro_update_metadata_request_v3);
fields(kpro_update_metadata_request_v3_partition_state) ->
record_info(fields, kpro_update_metadata_request_v3_partition_state);
fields(kpro_update_metadata_request_v3_live_broker) ->
record_info(fields, kpro_update_metadata_request_v3_live_broker);
fields(kpro_update_metadata_request_v3_end_point) ->
record_info(fields, kpro_update_metadata_request_v3_end_point);
fields(kpro_update_metadata_response_v0) ->
record_info(fields, kpro_update_metadata_response_v0);
fields(kpro_update_metadata_response_v1) ->
record_info(fields, kpro_update_metadata_response_v1);
fields(kpro_update_metadata_response_v2) ->
record_info(fields, kpro_update_metadata_response_v2);
fields(kpro_update_metadata_response_v3) ->
record_info(fields, kpro_update_metadata_response_v3);
fields(kpro_controlled_shutdown_request_v1) ->
record_info(fields, kpro_controlled_shutdown_request_v1);
fields(kpro_controlled_shutdown_response_v1) ->
record_info(fields, kpro_controlled_shutdown_response_v1);
fields(kpro_controlled_shutdown_response_v1_partitions_remaining) ->
record_info(fields, kpro_controlled_shutdown_response_v1_partitions_remaining);
fields(kpro_offset_commit_request_v0) ->
record_info(fields, kpro_offset_commit_request_v0);
fields(kpro_offset_commit_request_v0_topic) ->
record_info(fields, kpro_offset_commit_request_v0_topic);
fields(kpro_offset_commit_request_v0_partition) ->
record_info(fields, kpro_offset_commit_request_v0_partition);
fields(kpro_offset_commit_request_v1) ->
record_info(fields, kpro_offset_commit_request_v1);
fields(kpro_offset_commit_request_v1_topic) ->
record_info(fields, kpro_offset_commit_request_v1_topic);
fields(kpro_offset_commit_request_v1_partition) ->
record_info(fields, kpro_offset_commit_request_v1_partition);
fields(kpro_offset_commit_request_v2) ->
record_info(fields, kpro_offset_commit_request_v2);
fields(kpro_offset_commit_request_v2_topic) ->
record_info(fields, kpro_offset_commit_request_v2_topic);
fields(kpro_offset_commit_request_v2_partition) ->
record_info(fields, kpro_offset_commit_request_v2_partition);
fields(kpro_offset_commit_response_v0) ->
record_info(fields, kpro_offset_commit_response_v0);
fields(kpro_offset_commit_response_v0_response) ->
record_info(fields, kpro_offset_commit_response_v0_response);
fields(kpro_offset_commit_response_v0_partition_response) ->
record_info(fields, kpro_offset_commit_response_v0_partition_response);
fields(kpro_offset_commit_response_v1) ->
record_info(fields, kpro_offset_commit_response_v1);
fields(kpro_offset_commit_response_v1_response) ->
record_info(fields, kpro_offset_commit_response_v1_response);
fields(kpro_offset_commit_response_v1_partition_response) ->
record_info(fields, kpro_offset_commit_response_v1_partition_response);
fields(kpro_offset_commit_response_v2) ->
record_info(fields, kpro_offset_commit_response_v2);
fields(kpro_offset_commit_response_v2_response) ->
record_info(fields, kpro_offset_commit_response_v2_response);
fields(kpro_offset_commit_response_v2_partition_response) ->
record_info(fields, kpro_offset_commit_response_v2_partition_response);
fields(kpro_offset_fetch_request_v0) ->
record_info(fields, kpro_offset_fetch_request_v0);
fields(kpro_offset_fetch_request_v0_topic) ->
record_info(fields, kpro_offset_fetch_request_v0_topic);
fields(kpro_offset_fetch_request_v0_partition) ->
record_info(fields, kpro_offset_fetch_request_v0_partition);
fields(kpro_offset_fetch_request_v1) ->
record_info(fields, kpro_offset_fetch_request_v1);
fields(kpro_offset_fetch_request_v1_topic) ->
record_info(fields, kpro_offset_fetch_request_v1_topic);
fields(kpro_offset_fetch_request_v1_partition) ->
record_info(fields, kpro_offset_fetch_request_v1_partition);
fields(kpro_offset_fetch_request_v2) ->
record_info(fields, kpro_offset_fetch_request_v2);
fields(kpro_offset_fetch_request_v2_topic) ->
record_info(fields, kpro_offset_fetch_request_v2_topic);
fields(kpro_offset_fetch_request_v2_partition) ->
record_info(fields, kpro_offset_fetch_request_v2_partition);
fields(kpro_offset_fetch_response_v0) ->
record_info(fields, kpro_offset_fetch_response_v0);
fields(kpro_offset_fetch_response_v0_response) ->
record_info(fields, kpro_offset_fetch_response_v0_response);
fields(kpro_offset_fetch_response_v0_partition_response) ->
record_info(fields, kpro_offset_fetch_response_v0_partition_response);
fields(kpro_offset_fetch_response_v1) ->
record_info(fields, kpro_offset_fetch_response_v1);
fields(kpro_offset_fetch_response_v1_response) ->
record_info(fields, kpro_offset_fetch_response_v1_response);
fields(kpro_offset_fetch_response_v1_partition_response) ->
record_info(fields, kpro_offset_fetch_response_v1_partition_response);
fields(kpro_offset_fetch_response_v2) ->
record_info(fields, kpro_offset_fetch_response_v2);
fields(kpro_offset_fetch_response_v2_response) ->
record_info(fields, kpro_offset_fetch_response_v2_response);
fields(kpro_offset_fetch_response_v2_partition_response) ->
record_info(fields, kpro_offset_fetch_response_v2_partition_response);
fields(kpro_group_coordinator_request_v0) ->
record_info(fields, kpro_group_coordinator_request_v0);
fields(kpro_group_coordinator_response_v0) ->
record_info(fields, kpro_group_coordinator_response_v0);
fields(kpro_group_coordinator_response_v0_coordinator) ->
record_info(fields, kpro_group_coordinator_response_v0_coordinator);
fields(kpro_join_group_request_v0) ->
record_info(fields, kpro_join_group_request_v0);
fields(kpro_join_group_request_v0_group_protocol) ->
record_info(fields, kpro_join_group_request_v0_group_protocol);
fields(kpro_join_group_request_v1) ->
record_info(fields, kpro_join_group_request_v1);
fields(kpro_join_group_request_v1_group_protocol) ->
record_info(fields, kpro_join_group_request_v1_group_protocol);
fields(kpro_join_group_response_v0) ->
record_info(fields, kpro_join_group_response_v0);
fields(kpro_join_group_response_v0_member) ->
record_info(fields, kpro_join_group_response_v0_member);
fields(kpro_join_group_response_v1) ->
record_info(fields, kpro_join_group_response_v1);
fields(kpro_join_group_response_v1_member) ->
record_info(fields, kpro_join_group_response_v1_member);
fields(kpro_heartbeat_request_v0) ->
record_info(fields, kpro_heartbeat_request_v0);
fields(kpro_heartbeat_response_v0) ->
record_info(fields, kpro_heartbeat_response_v0);
fields(kpro_leave_group_request_v0) ->
record_info(fields, kpro_leave_group_request_v0);
fields(kpro_leave_group_response_v0) ->
record_info(fields, kpro_leave_group_response_v0);
fields(kpro_sync_group_request_v0) ->
record_info(fields, kpro_sync_group_request_v0);
fields(kpro_sync_group_request_v0_group_assignment) ->
record_info(fields, kpro_sync_group_request_v0_group_assignment);
fields(kpro_sync_group_response_v0) ->
record_info(fields, kpro_sync_group_response_v0);
fields(kpro_describe_groups_request_v0) ->
record_info(fields, kpro_describe_groups_request_v0);
fields(kpro_describe_groups_response_v0) ->
record_info(fields, kpro_describe_groups_response_v0);
fields(kpro_describe_groups_response_v0_group) ->
record_info(fields, kpro_describe_groups_response_v0_group);
fields(kpro_describe_groups_response_v0_member) ->
record_info(fields, kpro_describe_groups_response_v0_member);
fields(kpro_list_groups_request_v0) ->
record_info(fields, kpro_list_groups_request_v0);
fields(kpro_list_groups_response_v0) ->
record_info(fields, kpro_list_groups_response_v0);
fields(kpro_list_groups_response_v0_group) ->
record_info(fields, kpro_list_groups_response_v0_group);
fields(kpro_sasl_handshake_request_v0) ->
record_info(fields, kpro_sasl_handshake_request_v0);
fields(kpro_sasl_handshake_response_v0) ->
record_info(fields, kpro_sasl_handshake_response_v0);
fields(kpro_api_versions_request_v0) ->
record_info(fields, kpro_api_versions_request_v0);
fields(kpro_api_versions_response_v0) ->
record_info(fields, kpro_api_versions_response_v0);
fields(kpro_api_versions_response_v0_api_version) ->
record_info(fields, kpro_api_versions_response_v0_api_version);
fields(kpro_create_topics_request_v0) ->
record_info(fields, kpro_create_topics_request_v0);
fields(kpro_create_topics_request_v0_create_topic_request) ->
record_info(fields, kpro_create_topics_request_v0_create_topic_request);
fields(kpro_create_topics_request_v0_replica_assignment) ->
record_info(fields, kpro_create_topics_request_v0_replica_assignment);
fields(kpro_create_topics_request_v0_config) ->
record_info(fields, kpro_create_topics_request_v0_config);
fields(kpro_create_topics_request_v1) ->
record_info(fields, kpro_create_topics_request_v1);
fields(kpro_create_topics_request_v1_create_topic_request) ->
record_info(fields, kpro_create_topics_request_v1_create_topic_request);
fields(kpro_create_topics_request_v1_replica_assignment) ->
record_info(fields, kpro_create_topics_request_v1_replica_assignment);
fields(kpro_create_topics_request_v1_config) ->
record_info(fields, kpro_create_topics_request_v1_config);
fields(kpro_create_topics_response_v0) ->
record_info(fields, kpro_create_topics_response_v0);
fields(kpro_create_topics_response_v0_topic_error) ->
record_info(fields, kpro_create_topics_response_v0_topic_error);
fields(kpro_create_topics_response_v1) ->
record_info(fields, kpro_create_topics_response_v1);
fields(kpro_create_topics_response_v1_topic_error) ->
record_info(fields, kpro_create_topics_response_v1_topic_error);
fields(kpro_delete_topics_request_v0) ->
record_info(fields, kpro_delete_topics_request_v0);
fields(kpro_delete_topics_response_v0) ->
record_info(fields, kpro_delete_topics_response_v0);
fields(kpro_delete_topics_response_v0_topic_error_code) ->
record_info(fields, kpro_delete_topics_response_v0_topic_error_code);
fields(_Unknown) -> false.