[−][src]Module kafka::client
Kafka Client - A mid-level abstraction for a kafka cluster allowing building higher level constructs.
The entry point into this module is KafkaClient
obtained by a
call to KafkaClient::new()
.
Modules
fetch | A representation of fetched messages from Kafka. |
metadata | Types related to topic metadata for introspection by clients.
Example: |
Structs
CommitOffset | Data point identifying a particular topic partition offset to be
commited.
See |
FetchGroupOffset | Data point identifying a topic partition to fetch a group's offset
for. See |
FetchPartition | Partition related request data for fetching messages.
See |
KafkaClient | Client struct keeping track of brokers and topic metadata. |
PartitionOffset | A retrieved offset for a particular partition in the context of an already known topic. |
ProduceConfirm | A confirmation of messages sent back by the Kafka broker to confirm delivery of producer messages. |
ProduceMessage | Message data to be sent/produced to a particular topic partition.
See |
ProducePartitionConfirm | A confirmation of messages sent back by the Kafka broker to confirm delivery of producer messages for a particular topic. |
SecurityConfig | Security relevant configuration options for |
Enums
Compression | Compression types supported by kafka. The numeral values of this enumeration correspond to the compression encoding in the attributes of a Message in the protocol. |
FetchOffset | Possible values when querying a topic's offset.
See |
GroupOffsetStorage | Defines the availale storage types to utilize when fetching or
comitting group offsets. See also |
RequiredAcks | Possible choices on acknowledgement requirements when
producing/sending messages to Kafka. See
|
Constants
DEFAULT_COMPRESSION | The default value for |
DEFAULT_CONNECTION_IDLE_TIMEOUT_MILLIS | The default value for |
DEFAULT_FETCH_CRC_VALIDATION | The default value for |
DEFAULT_FETCH_MAX_BYTES_PER_PARTITION | The default value for |
DEFAULT_FETCH_MAX_WAIT_TIME_MILLIS | The default value for |
DEFAULT_FETCH_MIN_BYTES | The default value for |
DEFAULT_GROUP_OFFSET_STORAGE | The default value for |
DEFAULT_RETRY_BACKOFF_TIME_MILLIS | The default value for |
DEFAULT_RETRY_MAX_ATTEMPTS | The default value for |