Modern C++ Kafka API
Here is a list of all documented class members with links to the class documentation for each member:
- a -
abortTransaction() :
KAFKA_API::clients::producer::KafkaProducer
ackOffset() :
KAFKA_API::clients::consumer::UnorderedOffsetCommitQueue
ACKS :
KAFKA_API::clients::producer::ProducerConfig
ActionWhileQueueIsFull :
KAFKA_API::clients::producer::KafkaProducer
assign() :
KAFKA_API::clients::consumer::KafkaConsumer
assignment() :
KAFKA_API::clients::consumer::KafkaConsumer
AUTO_OFFSET_RESET :
KAFKA_API::clients::consumer::ConsumerConfig
- b -
BATCH_NUM_MESSAGES :
KAFKA_API::clients::producer::ProducerConfig
BATCH_SIZE :
KAFKA_API::clients::producer::ProducerConfig
beginningOffsets() :
KAFKA_API::clients::consumer::KafkaConsumer
beginTransaction() :
KAFKA_API::clients::producer::KafkaProducer
BOOTSTRAP_SERVERS :
KAFKA_API::clients::Config
BrokerMetadata() :
KAFKA_API::BrokerMetadata
BrokerStateChangeCb :
KAFKA_API::clients::Interceptors
- c -
CLIENT_ID :
KAFKA_API::clients::Config
clientId() :
KAFKA_API::clients::KafkaClient
close() :
KAFKA_API::clients::consumer::KafkaConsumer
,
KAFKA_API::clients::producer::KafkaProducer
commitAsync() :
KAFKA_API::clients::consumer::KafkaConsumer
commitSync() :
KAFKA_API::clients::consumer::KafkaConsumer
committed() :
KAFKA_API::clients::consumer::KafkaConsumer
commitTransaction() :
KAFKA_API::clients::producer::KafkaProducer
contains() :
KAFKA_API::Properties
createTopics() :
KAFKA_API::clients::admin::AdminClient
- d -
deleteRecords() :
KAFKA_API::clients::admin::AdminClient
deleteTopics() :
KAFKA_API::clients::admin::AdminClient
- e -
empty() :
KAFKA_API::clients::Interceptors
ENABLE_AUTO_COMMIT :
KAFKA_API::clients::consumer::ConsumerConfig
ENABLE_IDEMPOTENCE :
KAFKA_API::clients::producer::ProducerConfig
ENABLE_MANUAL_EVENTS_POLL :
KAFKA_API::clients::Config
ENABLE_PARTITION_EOF :
KAFKA_API::clients::consumer::ConsumerConfig
ENABLE_SASL_OAUTHBEARER_UNSECURE_JWT :
KAFKA_API::clients::Config
endOffsets() :
KAFKA_API::clients::consumer::KafkaConsumer
eraseProperty() :
KAFKA_API::Properties
error :
KAFKA_API::clients::admin::CreateTopicsResult
,
KAFKA_API::clients::admin::DeleteRecordsResult
,
KAFKA_API::clients::admin::DeleteTopicsResult
,
KAFKA_API::clients::admin::ListTopicsResult
,
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::KafkaException
ERROR_CB :
KAFKA_API::clients::Config
- f -
fetchBrokerMetadata() :
KAFKA_API::clients::KafkaClient
flush() :
KAFKA_API::clients::producer::KafkaProducer
- g -
get() :
KAFKA_API::Properties
getGroupId() :
KAFKA_API::clients::consumer::KafkaConsumer
getInt() :
KAFKA_API::KafkaMetrics
getNodeDescription() :
KAFKA_API::BrokerMetadata
getProperty() :
KAFKA_API::clients::KafkaClient
,
KAFKA_API::Properties
getString() :
KAFKA_API::KafkaMetrics
GROUP_ID :
KAFKA_API::clients::consumer::ConsumerConfig
groupMetadata() :
KAFKA_API::clients::consumer::KafkaConsumer
- h -
headers() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::ProducerRecord
host :
KAFKA_API::BrokerMetadata::Node
- i -
id :
KAFKA_API::BrokerMetadata::Node
,
KAFKA_API::clients::producer::ProducerRecord
initTransactions() :
KAFKA_API::clients::producer::KafkaProducer
inSyncReplicas :
KAFKA_API::BrokerMetadata::PartitionInfo
INTERCEPTORS :
KAFKA_API::clients::Config
isFatal() :
KAFKA_API::Error
ISOLATION_LEVEL :
KAFKA_API::clients::consumer::ConsumerConfig
isRetriable() :
KAFKA_API::Error
- k -
KafkaConsumer() :
KAFKA_API::clients::consumer::KafkaConsumer
KafkaMetrics() :
KAFKA_API::KafkaMetrics
KafkaProducer() :
KAFKA_API::clients::producer::KafkaProducer
key() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::ProducerRecord
keySize() :
KAFKA_API::clients::producer::RecordMetadata
- l -
lastHeaderValue() :
KAFKA_API::clients::consumer::ConsumerRecord
lastPoppedOffset() :
KAFKA_API::clients::consumer::UnorderedOffsetCommitQueue
leader :
KAFKA_API::BrokerMetadata::PartitionInfo
LINGER_MS :
KAFKA_API::clients::producer::ProducerConfig
listTopics() :
KAFKA_API::clients::admin::AdminClient
LOG_CB :
KAFKA_API::clients::Config
LOG_LEVEL :
KAFKA_API::clients::Config
- m -
map() :
KAFKA_API::Properties
MAX_IN_FLIGHT :
KAFKA_API::clients::producer::ProducerConfig
MAX_POLL_RECORDS :
KAFKA_API::clients::consumer::ConsumerConfig
message() :
KAFKA_API::Error
MESSAGE_MAX_BYTES :
KAFKA_API::clients::producer::ProducerConfig
MESSAGE_TIMEOUT_MS :
KAFKA_API::clients::producer::ProducerConfig
msSinceEpoch :
KAFKA_API::Timestamp
- n -
name() :
KAFKA_API::clients::KafkaClient
nodes() :
KAFKA_API::BrokerMetadata
- o -
OAUTHBEARER_TOKEN_REFRESH_CB :
KAFKA_API::clients::Config
offset() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::RecordMetadata
offsetsForTime() :
KAFKA_API::clients::consumer::KafkaConsumer
onBrokerStateChange() :
KAFKA_API::clients::Interceptors
onThreadExit() :
KAFKA_API::clients::Interceptors
onThreadStart() :
KAFKA_API::clients::Interceptors
operator bool() :
KAFKA_API::Error
operator std::error_code() :
KAFKA_API::Error
- p -
partition() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::ProducerRecord
,
KAFKA_API::clients::producer::RecordMetadata
PARTITIONER :
KAFKA_API::clients::producer::ProducerConfig
partitions() :
KAFKA_API::BrokerMetadata
pause() :
KAFKA_API::clients::consumer::KafkaConsumer
persistedStatus() :
KAFKA_API::clients::producer::RecordMetadata
poll() :
KAFKA_API::clients::consumer::KafkaConsumer
pollEvents() :
KAFKA_API::clients::KafkaClient
popOffsetToCommit() :
KAFKA_API::clients::consumer::UnorderedOffsetCommitQueue
port :
KAFKA_API::BrokerMetadata::Node
position() :
KAFKA_API::clients::consumer::KafkaConsumer
properties() :
KAFKA_API::clients::KafkaClient
purge() :
KAFKA_API::clients::producer::KafkaProducer
put() :
KAFKA_API::Properties
- q -
QUEUE_BUFFERING_MAX_KBYTES :
KAFKA_API::clients::producer::ProducerConfig
QUEUE_BUFFERING_MAX_MESSAGES :
KAFKA_API::clients::producer::ProducerConfig
QUEUED_MIN_MESSAGES :
KAFKA_API::clients::consumer::ConsumerConfig
- r -
recordId() :
KAFKA_API::clients::producer::RecordMetadata
remove() :
KAFKA_API::Properties
replicas :
KAFKA_API::BrokerMetadata::PartitionInfo
REQUEST_TIMEOUT_MS :
KAFKA_API::clients::producer::ProducerConfig
ResultsType :
KAFKA_API::KafkaMetrics
resume() :
KAFKA_API::clients::consumer::KafkaConsumer
- s -
SASL_KERBEROS_KINIT_CMD :
KAFKA_API::clients::Config
SASL_KERBEROS_SERVICE_NAME :
KAFKA_API::clients::Config
SASL_MECHANISM :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_CLIENT_ID :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_CLIENT_SECRET :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_CONFIG :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_EXTENSIONS :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_METHOD :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_SCOPE :
KAFKA_API::clients::Config
SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL :
KAFKA_API::clients::Config
SASL_PASSWORD :
KAFKA_API::clients::Config
SASL_USERNAME :
KAFKA_API::clients::Config
SECURITY_PROTOCOL :
KAFKA_API::clients::Config
seek() :
KAFKA_API::clients::consumer::KafkaConsumer
seekToBeginning() :
KAFKA_API::clients::consumer::KafkaConsumer
seekToEnd() :
KAFKA_API::clients::consumer::KafkaConsumer
send() :
KAFKA_API::clients::producer::KafkaProducer
sendOffsetsToTransaction() :
KAFKA_API::clients::producer::KafkaProducer
SendOption :
KAFKA_API::clients::producer::KafkaProducer
SESSION_TIMEOUT_MS :
KAFKA_API::clients::consumer::ConsumerConfig
setGroupId() :
KAFKA_API::clients::consumer::KafkaConsumer
setId() :
KAFKA_API::clients::producer::ProducerRecord
setKey() :
KAFKA_API::clients::producer::ProducerRecord
setLogLevel() :
KAFKA_API::clients::KafkaClient
setPartition() :
KAFKA_API::clients::producer::ProducerRecord
setValue() :
KAFKA_API::clients::producer::ProducerRecord
size() :
KAFKA_API::clients::consumer::UnorderedOffsetCommitQueue
SOCKET_TIMEOUT_MS :
KAFKA_API::clients::Config
STATS_CB :
KAFKA_API::clients::Config
subscribe() :
KAFKA_API::clients::consumer::KafkaConsumer
subscription() :
KAFKA_API::clients::consumer::KafkaConsumer
syncSend() :
KAFKA_API::clients::producer::KafkaProducer
- t -
ThreadExitCb :
KAFKA_API::clients::Interceptors
ThreadStartCb :
KAFKA_API::clients::Interceptors
timestamp() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::RecordMetadata
topic() :
KAFKA_API::BrokerMetadata
,
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::ProducerRecord
,
KAFKA_API::clients::producer::RecordMetadata
topics :
KAFKA_API::clients::admin::ListTopicsResult
toString() :
KAFKA_API::BrokerMetadata::Node
,
KAFKA_API::BrokerMetadata
,
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::Error
,
KAFKA_API::Header
,
KAFKA_API::Timestamp
TRANSACTION_TIMEOUT_MS :
KAFKA_API::clients::producer::ProducerConfig
TRANSACTIONAL_ID :
KAFKA_API::clients::producer::ProducerConfig
transactionRequiresAbort() :
KAFKA_API::Error
type :
KAFKA_API::Timestamp
- u -
unsubscribe() :
KAFKA_API::clients::consumer::KafkaConsumer
- v -
value() :
KAFKA_API::clients::consumer::ConsumerRecord
,
KAFKA_API::clients::producer::ProducerRecord
,
KAFKA_API::Error
valueSize() :
KAFKA_API::clients::producer::RecordMetadata
- w -
waitOffset() :
KAFKA_API::clients::consumer::UnorderedOffsetCommitQueue
what() :
KAFKA_API::KafkaException
- ~ -
~KafkaConsumer() :
KAFKA_API::clients::consumer::KafkaConsumer
~KafkaProducer() :
KAFKA_API::clients::producer::KafkaProducer
Generated on Wed Jul 3 2024 09:31:01 for Modern C++ Kafka API by
1.9.1