|
Modern C++ Kafka API
|
| ▼NKAFKA_API | |
| ▼Nclients | |
| ▼Nadmin | |
| CAdminClient | The administrative client for Kafka, which supports managing and inspecting topics, etc |
| CAdminClientConfig | Configuration for the Kafka Consumer |
| CCreateTopicsResult | The result of AdminClient::createTopics() |
| CDeleteTopicsResult | The result of AdminClient::deleteTopics() |
| CDeleteRecordsResult | The result of AdminClient::deleteRecords() |
| CListTopicsResult | The result of AdminClient::listTopics() |
| ▼Nconsumer | |
| CUnorderedOffsetCommitQueue | The queue can be used to determine the right offset to commit |
| CConsumerGroupMetadata | A metadata struct containing the consumer group information |
| CConsumerConfig | Configuration for the Kafka Consumer |
| CConsumerRecord | A key/value pair to be received from Kafka |
| CKafkaConsumer | KafkaConsumer class |
| ▼Nproducer | |
| CKafkaProducer | KafkaProducer class |
| CRecordMetadata | The metadata for a record that has been acknowledged by the server |
| CProducerConfig | Configuration for the Kafka Producer |
| CProducerRecord | A key/value pair to be sent to Kafka |
| CSaslOauthbearerToken | SASL OAUTHBEARER token info |
| CConfig | Configuration for Kafka clients |
| CInterceptors | Interceptors for Kafka clients |
| CKafkaClient | The base class for Kafka clients |
| CKafkaMetrics | Helps to parse the metrics string with JSON format |
| ▼CBrokerMetadata | The metadata info for a topic |
| CNode | Information for a Kafka node |
| CPartitionInfo | It is used to describe per-partition state in the MetadataResponse |
| CError | Unified error type |
| CHeader | Message Header (with a key value pair) |
| CKafkaException | Specific exception for Kafka clients |
| CProperties | The properties for Kafka clients |
| CTimestamp | The time point together with the type |
1.9.1