|
Modern C++ Kafka API
|
This is the complete list of members for KAFKA_API::clients::consumer::KafkaConsumer, including all inherited members.
| assign(const TopicPartitions &topicPartitions) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| assignment() const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| beginningOffsets(const TopicPartitions &topicPartitions, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_QUERY_TIMEOUT_MS)) const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| clientId() const | KAFKA_API::clients::KafkaClient | inline |
| close() | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitAsync(const consumer::OffsetCommitCallback &offsetCommitCallback=consumer::NullOffsetCommitCallback) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitAsync(const consumer::ConsumerRecord &record, const consumer::OffsetCommitCallback &offsetCommitCallback=consumer::NullOffsetCommitCallback) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitAsync(const TopicPartitionOffsets &topicPartitionOffsets, const consumer::OffsetCommitCallback &offsetCommitCallback=consumer::NullOffsetCommitCallback) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitSync() | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitSync(const consumer::ConsumerRecord &record) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| commitSync(const TopicPartitionOffsets &topicPartitionOffsets) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| committed(const TopicPartition &topicPartition) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| DEFAULT_MAX_POLL_RECORDS_VALUE (defined in KAFKA_API::clients::consumer::KafkaConsumer) | KAFKA_API::clients::consumer::KafkaConsumer | static |
| DEFAULT_METADATA_TIMEOUT_MS enum value (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | |
| 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 |
| endOffsets(const TopicPartitions &topicPartitions, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_QUERY_TIMEOUT_MS)) const | KAFKA_API::clients::consumer::KafkaConsumer | 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 |
| getGroupId() const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| getProperty(const std::string &name) const | KAFKA_API::clients::KafkaClient | inline |
| groupMetadata() | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| KafkaConsumer(const Properties &properties) | KAFKA_API::clients::consumer::KafkaConsumer | inlineexplicit |
| name() const | KAFKA_API::clients::KafkaClient | inline |
| offsetsForTime(const TopicPartitions &topicPartitions, std::chrono::time_point< std::chrono::system_clock > timepoint, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_QUERY_TIMEOUT_MS)) const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| pause(const TopicPartitions &topicPartitions) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| pause() | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| poll(std::chrono::milliseconds timeout) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| pollEvents(std::chrono::milliseconds timeout) | KAFKA_API::clients::KafkaClient | inline |
| position(const TopicPartition &topicPartition) const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| properties() const | KAFKA_API::clients::KafkaClient | inline |
| resume(const TopicPartitions &topicPartitions) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| resume() | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| seek(const TopicPartition &topicPartition, Offset offset, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SEEK_TIMEOUT_MS)) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| seekToBeginning(const TopicPartitions &topicPartitions, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SEEK_TIMEOUT_MS)) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| seekToBeginning(std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SEEK_TIMEOUT_MS)) (defined in KAFKA_API::clients::consumer::KafkaConsumer) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| seekToEnd(const TopicPartitions &topicPartitions, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SEEK_TIMEOUT_MS)) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| seekToEnd(std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SEEK_TIMEOUT_MS)) (defined in KAFKA_API::clients::consumer::KafkaConsumer) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| setGroupId(const std::string &id) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| setLogLevel(int level) | KAFKA_API::clients::KafkaClient | inline |
| subscribe(const Topics &topics, consumer::RebalanceCallback rebalanceCallback=consumer::NullRebalanceCallback, std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_SUBSCRIBE_TIMEOUT_MS)) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| subscription() const | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| unsubscribe(std::chrono::milliseconds timeout=std::chrono::milliseconds(DEFAULT_UNSUBSCRIBE_TIMEOUT_MS)) | KAFKA_API::clients::consumer::KafkaConsumer | inline |
| ~KafkaClient()=default (defined in KAFKA_API::clients::KafkaClient) | KAFKA_API::clients::KafkaClient | virtual |
| ~KafkaConsumer() override | KAFKA_API::clients::consumer::KafkaConsumer | inline |
1.9.1