class OffsetFetchResponse

Header File: <libkafka_asio/offset_fetch_response.h>

Namespace: libkafka_asio

Implementation of the Kafka OffsetFetchResponse as described on the Kafka wiki. An object of this type will be given as response object to the handler function when invoking an offset fetch request.

Member Functions

topics

const TopicVector& topics() const

Returns a list of topics of this response

Types

Topic

struct Topic
  • topic_name: Name of the topic to fetch data for.
  • partition_offsets: Set of partitions of this topic for which offset data has been received.

Topic::Partition

struct Topic::Partition
  • partition: Number, identifying this topic partition.
  • error_code: Kafka error for this topic partition.
  • offset: The offset data, stored for this topic partition
  • metadata: The metadata string, stored for this topic partition

TopicVector

typedef std::vector<Topic> TopicVector

Vector of Topic structures.

OptionalType

typedef boost::optional<OffsetFetchResponse> OptionalType

A offset-fetch response object wrapped using Boost optional. Such an object will be used for offset-fetch request handler functions.