|
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 |