View Source API Reference kayrock v0.2.0
Modules
Documentation for Kayrock.
Kayrock-generated module for the Kafka add_offsets_to_txn API
Kayrock-generated request struct for Kafka add_offsets_to_txn v0 API
messages
Kayrock-generated response struct for Kafka add_offsets_to_txn v0 API
messages
Kayrock-generated module for the Kafka add_partitions_to_txn API
Kayrock-generated request struct for Kafka add_partitions_to_txn v0 API
messages
Kayrock-generated response struct for Kafka add_partitions_to_txn v0 API
messages
Kayrock-generated module for the Kafka alter_configs API
Kayrock-generated request struct for Kafka alter_configs v0 API
messages
Kayrock-generated response struct for Kafka alter_configs v0 API
messages
Kayrock-generated module for the Kafka alter_replica_log_dirs API
Kayrock-generated request struct for Kafka alter_replica_log_dirs v0 API
messages
Kayrock-generated response struct for Kafka alter_replica_log_dirs v0 API
messages
Kayrock-generated module for the Kafka api_versions API
Kayrock-generated request struct for Kafka api_versions v0 API
messages
Kayrock-generated response struct for Kafka api_versions v0 API
messages
Kayrock-generated request struct for Kafka api_versions v1 API
messages
Kayrock-generated response struct for Kafka api_versions v1 API
messages
A connection to a kafka broker.
Manages communication with a single cluster
Encapsulates what we know about the state of a Kafka broker cluster
Handles compression/decompression of messages.
Convenience functions for working with Kayrock / Kafka API data
Kayrock-generated module for the Kafka create_acls API
Kayrock-generated request struct for Kafka create_acls v0 API
messages
Kayrock-generated response struct for Kafka create_acls v0 API
messages
Kayrock-generated module for the Kafka create_delegation_token API
Kayrock-generated request struct for Kafka create_delegation_token v0 API
messages
Kayrock-generated response struct for Kafka create_delegation_token v0 API
messages
Kayrock-generated module for the Kafka create_partitions API
Kayrock-generated request struct for Kafka create_partitions v0 API
messages
Kayrock-generated response struct for Kafka create_partitions v0 API
messages
Kayrock-generated module for the Kafka create_topics API
Kayrock-generated request struct for Kafka create_topics v0 API
messages
Kayrock-generated response struct for Kafka create_topics v0 API
messages
Kayrock-generated request struct for Kafka create_topics v1 API
messages
Kayrock-generated response struct for Kafka create_topics v1 API
messages
Kayrock-generated request struct for Kafka create_topics v2 API
messages
Kayrock-generated response struct for Kafka create_topics v2 API
messages
Kayrock-generated module for the Kafka delete_acls API
Kayrock-generated request struct for Kafka delete_acls v0 API
messages
Kayrock-generated response struct for Kafka delete_acls v0 API
messages
Kayrock-generated module for the Kafka delete_groups API
Kayrock-generated request struct for Kafka delete_groups v0 API
messages
Kayrock-generated response struct for Kafka delete_groups v0 API
messages
Kayrock-generated module for the Kafka delete_records API
Kayrock-generated request struct for Kafka delete_records v0 API
messages
Kayrock-generated response struct for Kafka delete_records v0 API
messages
Kayrock-generated module for the Kafka delete_topics API
Kayrock-generated request struct for Kafka delete_topics v0 API
messages
Kayrock-generated response struct for Kafka delete_topics v0 API
messages
Kayrock-generated request struct for Kafka delete_topics v1 API
messages
Kayrock-generated response struct for Kafka delete_topics v1 API
messages
Kayrock-generated module for the Kafka describe_acls API
Kayrock-generated request struct for Kafka describe_acls v0 API
messages
Kayrock-generated response struct for Kafka describe_acls v0 API
messages
Kayrock-generated module for the Kafka describe_configs API
Kayrock-generated request struct for Kafka describe_configs v0 API
messages
Kayrock-generated response struct for Kafka describe_configs v0 API
messages
Kayrock-generated request struct for Kafka describe_configs v1 API
messages
Kayrock-generated response struct for Kafka describe_configs v1 API
messages
Kayrock-generated module for the Kafka describe_delegation_token API
Kayrock-generated request struct for Kafka describe_delegation_token v0 API
messages
Kayrock-generated response struct for Kafka describe_delegation_token v0 API
messages
Kayrock-generated module for the Kafka describe_groups API
Kayrock-generated request struct for Kafka describe_groups v0 API
messages
Kayrock-generated response struct for Kafka describe_groups v0 API
messages
Kayrock-generated request struct for Kafka describe_groups v1 API
messages
Kayrock-generated response struct for Kafka describe_groups v1 API
messages
Kayrock-generated module for the Kafka describe_log_dirs API
Kayrock-generated request struct for Kafka describe_log_dirs v0 API
messages
Kayrock-generated response struct for Kafka describe_log_dirs v0 API
messages
Deserialization for primitive types for the kafka protocol
Kayrock-generated module for the Kafka end_txn API
Kayrock-generated request struct for Kafka end_txn v0 API
messages
Kayrock-generated response struct for Kafka end_txn v0 API
messages
Utility for converting Kafka error codes to/from atom names
Raised if Kayrock.ErrorCode.atom_to_code!/1 is called with an atom that
does not correspond to a known Kafka error code.
Raised if Kayrock.ErrorCode.code_to_atom!/1 is called with a code that
does not correspond to a known Kafka error code.
Kayrock-generated module for the Kafka expire_delegation_token API
Kayrock-generated request struct for Kafka expire_delegation_token v0 API
messages
Kayrock-generated response struct for Kafka expire_delegation_token v0 API
messages
Kayrock-generated module for the Kafka fetch API
Kayrock-generated request struct for Kafka fetch v0 API
messages
Kayrock-generated response struct for Kafka fetch v0 API
messages
Kayrock-generated request struct for Kafka fetch v1 API
messages
Kayrock-generated response struct for Kafka fetch v1 API
messages
Kayrock-generated request struct for Kafka fetch v2 API
messages
Kayrock-generated response struct for Kafka fetch v2 API
messages
Kayrock-generated request struct for Kafka fetch v3 API
messages
Kayrock-generated response struct for Kafka fetch v3 API
messages
Kayrock-generated request struct for Kafka fetch v4 API
messages
Kayrock-generated response struct for Kafka fetch v4 API
messages
Kayrock-generated request struct for Kafka fetch v5 API
messages
Kayrock-generated response struct for Kafka fetch v5 API
messages
Kayrock-generated request struct for Kafka fetch v6 API
messages
Kayrock-generated response struct for Kafka fetch v6 API
messages
Kayrock-generated request struct for Kafka fetch v7 API
messages
Kayrock-generated response struct for Kafka fetch v7 API
messages
Kayrock-generated module for the Kafka find_coordinator API
Kayrock-generated request struct for Kafka find_coordinator v0 API
messages
Kayrock-generated response struct for Kafka find_coordinator v0 API
messages
Kayrock-generated request struct for Kafka find_coordinator v1 API
messages
Kayrock-generated response struct for Kafka find_coordinator v1 API
messages
Macros for generating modules for the protocol schema
Code to serialize consumer group ProtocolMetadata messages
Kayrock-generated module for the Kafka heartbeat API
Kayrock-generated request struct for Kafka heartbeat v0 API
messages
Kayrock-generated response struct for Kafka heartbeat v0 API
messages
Kayrock-generated request struct for Kafka heartbeat v1 API
messages
Kayrock-generated response struct for Kafka heartbeat v1 API
messages
Kayrock-generated module for the Kafka init_producer_id API
Kayrock-generated request struct for Kafka init_producer_id v0 API
messages
Kayrock-generated response struct for Kafka init_producer_id v0 API
messages
Raised on serialization errors
Kayrock-generated module for the Kafka join_group API
Kayrock-generated request struct for Kafka join_group v0 API
messages
Kayrock-generated response struct for Kafka join_group v0 API
messages
Kayrock-generated request struct for Kafka join_group v1 API
messages
Kayrock-generated response struct for Kafka join_group v1 API
messages
Kayrock-generated request struct for Kafka join_group v2 API
messages
Kayrock-generated response struct for Kafka join_group v2 API
messages
Kayrock-generated module for the Kafka leave_group API
Kayrock-generated request struct for Kafka leave_group v0 API
messages
Kayrock-generated response struct for Kafka leave_group v0 API
messages
Kayrock-generated request struct for Kafka leave_group v1 API
messages
Kayrock-generated response struct for Kafka leave_group v1 API
messages
Kayrock-generated module for the Kafka list_groups API
Kayrock-generated request struct for Kafka list_groups v0 API
messages
Kayrock-generated response struct for Kafka list_groups v0 API
messages
Kayrock-generated request struct for Kafka list_groups v1 API
messages
Kayrock-generated response struct for Kafka list_groups v1 API
messages
Kayrock-generated module for the Kafka list_offsets API
Kayrock-generated request struct for Kafka list_offsets v0 API
messages
Kayrock-generated response struct for Kafka list_offsets v0 API
messages
Kayrock-generated request struct for Kafka list_offsets v1 API
messages
Kayrock-generated response struct for Kafka list_offsets v1 API
messages
Kayrock-generated request struct for Kafka list_offsets v2 API
messages
Kayrock-generated response struct for Kafka list_offsets v2 API
messages
Useful macros for kafka-related values
Code to serialize/deserialize Kafka consumer group member assignments
Represents partition assignments for a specific topic
Represents a set of messages with the v0 or v1 format
Represents a single message with the v0 or v1 format
Kayrock-generated module for the Kafka metadata API
Kayrock-generated request struct for Kafka metadata v0 API
messages
Kayrock-generated response struct for Kafka metadata v0 API
messages
Kayrock-generated request struct for Kafka metadata v1 API
messages
Kayrock-generated response struct for Kafka metadata v1 API
messages
Kayrock-generated request struct for Kafka metadata v2 API
messages
Kayrock-generated response struct for Kafka metadata v2 API
messages
Kayrock-generated request struct for Kafka metadata v3 API
messages
Kayrock-generated response struct for Kafka metadata v3 API
messages
Kayrock-generated request struct for Kafka metadata v4 API
messages
Kayrock-generated response struct for Kafka metadata v4 API
messages
Kayrock-generated request struct for Kafka metadata v5 API
messages
Kayrock-generated response struct for Kafka metadata v5 API
messages
Kayrock-generated module for the Kafka offset_commit API
Kayrock-generated request struct for Kafka offset_commit v0 API
messages
Kayrock-generated response struct for Kafka offset_commit v0 API
messages
Kayrock-generated request struct for Kafka offset_commit v1 API
messages
Kayrock-generated response struct for Kafka offset_commit v1 API
messages
Kayrock-generated request struct for Kafka offset_commit v2 API
messages
Kayrock-generated response struct for Kafka offset_commit v2 API
messages
Kayrock-generated request struct for Kafka offset_commit v3 API
messages
Kayrock-generated response struct for Kafka offset_commit v3 API
messages
Kayrock-generated module for the Kafka offset_fetch API
Kayrock-generated request struct for Kafka offset_fetch v0 API
messages
Kayrock-generated response struct for Kafka offset_fetch v0 API
messages
Kayrock-generated request struct for Kafka offset_fetch v1 API
messages
Kayrock-generated response struct for Kafka offset_fetch v1 API
messages
Kayrock-generated request struct for Kafka offset_fetch v2 API
messages
Kayrock-generated response struct for Kafka offset_fetch v2 API
messages
Kayrock-generated request struct for Kafka offset_fetch v3 API
messages
Kayrock-generated response struct for Kafka offset_fetch v3 API
messages
Kayrock-generated module for the Kafka produce API
Kayrock-generated request struct for Kafka produce v0 API
messages
Kayrock-generated response struct for Kafka produce v0 API
messages
Kayrock-generated request struct for Kafka produce v1 API
messages
Kayrock-generated response struct for Kafka produce v1 API
messages
Kayrock-generated request struct for Kafka produce v2 API
messages
Kayrock-generated response struct for Kafka produce v2 API
messages
Kayrock-generated request struct for Kafka produce v3 API
messages
Kayrock-generated response struct for Kafka produce v3 API
messages
Kayrock-generated request struct for Kafka produce v4 API
messages
Kayrock-generated response struct for Kafka produce v4 API
messages
Kayrock-generated request struct for Kafka produce v5 API
messages
Kayrock-generated response struct for Kafka produce v5 API
messages
Represents a batch of records (also called a record set)
Represents a single record (message)
Represents a record header
Kayrock-generated module for the Kafka renew_delegation_token API
Kayrock-generated request struct for Kafka renew_delegation_token v0 API
messages
Kayrock-generated response struct for Kafka renew_delegation_token v0 API
messages
Kayrock-generated module for the Kafka sasl_authenticate API
Kayrock-generated request struct for Kafka sasl_authenticate v0 API
messages
Kayrock-generated response struct for Kafka sasl_authenticate v0 API
messages
Kayrock-generated module for the Kafka sasl_handshake API
Kayrock-generated request struct for Kafka sasl_handshake v0 API
messages
Kayrock-generated response struct for Kafka sasl_handshake v0 API
messages
Kayrock-generated request struct for Kafka sasl_handshake v1 API
messages
Kayrock-generated response struct for Kafka sasl_handshake v1 API
messages
Serializations for primitive types for the kafka protocol
This module handle all socket related operations.
Kayrock-generated module for the Kafka sync_group API
Kayrock-generated request struct for Kafka sync_group v0 API
messages
Kayrock-generated response struct for Kafka sync_group v0 API
messages
Kayrock-generated request struct for Kafka sync_group v1 API
messages
Kayrock-generated response struct for Kafka sync_group v1 API
messages
Kayrock-generated module for the Kafka txn_offset_commit API
Kayrock-generated request struct for Kafka txn_offset_commit v0 API
messages
Kayrock-generated response struct for Kafka txn_offset_commit v0 API
messages
Mix Tasks
Mix task to generate the .ex files for each of the kafka protocol messages