List of all items
Structs
- CloseOptions
- Consumer
- ConsumerFetchMaxBytes
- ConsumerFetchPartitionMaxBytes
- ConsumerGroupMetadata
- ConsumerLeaveGroupTimeout
- ConsumerRecord
- ConsumerRetryPolicy
- ConsumerSubscriptionMetadataRefreshInterval
- Header
- Node
- OffsetAndMetadata
- OffsetAndTimestamp
- PartitionInfo
- ShareConsumer
- ShareConsumerFetchMaxBytes
- ShareConsumerFetchMaxRecords
- ShareConsumerFetchMinBytes
- ShareConsumerLeaveHeartbeatTimeout
- ShareConsumerRecord
- TopicPattern
- WakeupHandle
Enums
- Assignor
- AutoOffsetReset
- ConsumerError
- GroupMembershipOperation
- GroupProtocol
- IsolationLevel
- ShareAckMode
- ShareAckType
- ShareAcquireMode
- TimestampType
Traits
Type Aliases
Constants
- DEFAULT_CONSUMER_CLOSE_TIMEOUT
- DEFAULT_CONSUMER_DEFAULT_API_TIMEOUT
- DEFAULT_CONSUMER_FETCH_MAX_WAIT
- DEFAULT_CONSUMER_LEAVE_GROUP_TIMEOUT
- DEFAULT_CONSUMER_MAX_POLL_INTERVAL
- DEFAULT_CONSUMER_MAX_POLL_RECORDS
- DEFAULT_CONSUMER_METADATA_MAX_AGE
- DEFAULT_CONSUMER_SUBSCRIPTION_METADATA_REFRESH_INTERVAL
- DEFAULT_SHARE_CONSUMER_FETCH_MAX
- DEFAULT_SHARE_CONSUMER_FETCH_MAX_RECORDS
- DEFAULT_SHARE_CONSUMER_FETCH_MIN
- DEFAULT_SHARE_CONSUMER_LEAVE_HEARTBEAT_TIMEOUT