Modern C++ Kafka API
|
This is the complete list of members for KAFKA_API::clients::admin::AdminClient, including all inherited members.
AdminClient(const Properties &properties) (defined in KAFKA_API::clients::admin::AdminClient) | KAFKA_API::clients::admin::AdminClient | inlineexplicit |
clientId() const | KAFKA_API::clients::KafkaClient | inline |
createTopics(const Topics &topics, int numPartitions, int replicationFactor, const Properties &topicConfig=Properties(), std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_COMMAND_TIMEOUT_MS)) | KAFKA_API::clients::admin::AdminClient | inline |
DEFAULT_METADATA_TIMEOUT_MS enum value (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | |
deleteRecords(const TopicPartitionOffsets &topicPartitionOffsets, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_COMMAND_TIMEOUT_MS)) | KAFKA_API::clients::admin::AdminClient | inline |
deleteTopics(const Topics &topics, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_COMMAND_TIMEOUT_MS)) | KAFKA_API::clients::admin::AdminClient | inline |
doLog(int level, const char *filename, int lineno, const char *format, Args... args) const (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | inline |
doLog(int level, const char *filename, int lineno, const char *msg) const (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | inline |
fetchBrokerMetadata(const std::string &topic, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_METADATA_TIMEOUT_MS), bool disableErrorLogging=false) | KAFKA_API::clients::KafkaClient | inline |
getProperty(const std::string &name) const | KAFKA_API::clients::KafkaClient | inline |
listTopics(std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_COMMAND_TIMEOUT_MS)) | KAFKA_API::clients::admin::AdminClient | inline |
name() const | KAFKA_API::clients::KafkaClient | inline |
pollEvents(std::chrono::milliseconds timeout) | KAFKA_API::clients::KafkaClient | inline |
properties() const | KAFKA_API::clients::KafkaClient | inline |
setLogLevel(int level) | KAFKA_API::clients::KafkaClient | inline |
~KafkaClient()=default (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | virtual |