@spec cluster_metadata(client()) :: {:ok, KafkaEx.New.Structs.ClusterMetadata.t()}

Returns the cluster metadata from the given client

@spec correlation_id(client()) :: {:ok, correlation_id()}

Returns the current correlation id for the given client

@spec describe_group(client(), Keyword.t()) ::
  {:ok, KafkaEx.New.Structs.ConsumerGroup.t()} | {:error, any()}

Sends a request to describe a group identified by its name. We support only one consumer group per request for now, as we don't group requests by group coordinator.

@spec latest_offset(client(), topic_name(), partition_id()) ::
  {:error, error_atom()} | {:ok, offset()}

Fetch the latest offset for a given partition

@spec set_consumer_group_for_auto_commit(client(), consumer_group_name()) ::
  :ok | {:error, :invalid_consumer_group}

Set the consumer group name that will be used by the given client for autocommit

NOTE this function will not be supported after the legacy API is removed

@spec topics_metadata(client(), [topic_name()], boolean()) ::
  {:ok, [KafkaEx.New.Structs.Topic.t()]}

Get topic metadata for the given topics

Always calls out to the broker to get the most up-to-date metadata (and subsequently updates the client's state with the updated metadata). Set allow_topic_creation to true to allow the topics to be created if they don't exist