class `FetchResponse`

Header File: <libkafka_asio/fetch_response.h>

Namespace: libkafka_asio

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

Member Functions

begin

const_iterator begin() const

Creates and returns an iterator object that can be used for iterating over all received messages. This function returns the start iterator object.

// Assume the response is an argument of the request handler function
FetchResponse::OptionalType response;

// C++11 range-based for loop
for (auto message : *response)
{
    // Do something with the message...
}

// STL for_each
std::for_each(response->begin(), response->end(), &PrintMessage);

// 'traditional' iteration
FetchResponse::const_iterator iter = response->begin();
FetchResponse::const_iterator end_iter = response->end();
for (; iter != end_iter; ++iter)
{
    // Again do something...
}

end

const_iterator end() const

End iterator (see start iterator description above). Similar to default construction of the const_iterator type.

topics

const TopicVector& topics() const

Returns a reference to the set of topics, messages have been received for.

Types

Topic

struct Topic

topic_name: Name of this topic.
partitions: Set of partitions of this topic for which message data has been received.

Topic::Partition

struct Topic::Partition

partition: Number, identifying this topic partition.
error_code: Kafka error for this topic partition.
highwater_mark_offset: Offset at the end of the log for this partition on the server.

TopicVector

typedef std::vector<Topic> TopicVector

Vector of Topic structures.

const_iterator

typedef defail::FetchResponseIterator<TopicVector> const_iterator

Constant iterator type, used for iterating over all messages of a fetch response object. See FetchResponseIterator class template for details.

OptionalType

typedef boost::optional<FetchResponse> OptionalType

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

class FetchResponse