@spec api_versions_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for ApiVersions API

@spec create_topics_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for CreateTopics API

Options

• topics (required): List of topic configurations, each with:
  • :topic - Topic name (required)
  • :num_partitions - Number of partitions (default: -1 for broker default)
  • :replication_factor - Replication factor (default: -1 for broker default)
  • :replica_assignment - Manual replica assignment (default: [])
  • :config_entries - Topic configuration entries (default: [])
• timeout (required): Request timeout in milliseconds
• validate_only (optional, V1+): If true, only validate without creating
• api_version (optional): API version to use (default: 1)

@spec delete_topics_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Delete Topics API

@spec describe_groups_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Describe Groups API

@spec fetch_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Fetch API

Version-specific logic is handled by the protocol layer (RequestHelpers). This function simply passes all options through to the protocol.

@spec find_coordinator_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for FindCoordinator API

Options

• group_id (required for V0, optional for V1): The consumer group ID
• coordinator_key (optional, V1): The key to look up (defaults to group_id)
• coordinator_type (optional, V1): 0 for group (default), 1 for transaction
• api_version (optional): API version to use (default: 1)

@spec heartbeat_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Heartbeat API

@spec join_group_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for JoinGroup API

Version-specific logic is handled by the protocol layer (RequestHelpers). This function simply passes all options through to the protocol.

@spec leave_group_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for LeaveGroup API

@spec lists_offset_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for List Offsets API

@spec metadata_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Metadata API

@spec offset_commit_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Offset Commit API

Version-specific logic is handled by the protocol layer (RequestHelpers). This function simply passes all options through to the protocol.

@spec offset_fetch_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Offset Fetch API

@spec produce_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Produce API

Version-specific logic is handled by the protocol layer (RequestHelpers). This function simply passes all options through to the protocol.

@spec sync_group_request(Keyword.t(), KafkaEx.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for SyncGroup API