API Reference kayrock v0.1.12

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

Functions to help debugging binaries

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 task to generate the .ex files for each of the kafka protocol messages