Struct KafkaTopicDetails

Struct Documentation

struct KafkaTopicDetails

Convenience struct for Kafka topics that combine the connection details and topic.

Public Functions

KafkaTopicDetails(const std::string &uri)

Construct a new KafkaTopicDetails.

Parameters

uri – the connection URI the generate the object from

Throws

a – runtime exception if the the URI is not of the form “<scheme>://<address>/<topic>”

inline KafkaTopicDetails(std::string scheme, std::string address, std::string topic)

Construct a new KafkaTopicDetails.

Parameters

  • scheme – the scheme for topic details

  • address – the address (e.g. host and port) of the Kafka server to send messages to.

  • topic – the Kafka topic to send messages to

Public Members

KafkaConnectionDetails connection

The connection details for the topic.

std::string topic

The Kafka topic to send messages to.