Modules§
- admin
- Admin client.
- bindings
- FFI bindings.
- client
- Common client functionality.
- config
- Producer and consumer configuration.
- configuration
- consumer
- Kafka consumers.
- error
- Error manipulations.
- groups
- Group membership API.
- helpers
- Utility functions.
- hp_
producer - log_
wrap - message
- Store and manipulate Kafka messages.
- metadata
- Cluster metadata.
- mocking
- Mocking functionality
- producer
- Kafka producers.
- statistics
- Client and broker statistics.
- topic_
partition_ list - Data structures representing topic, partitions and offsets.
- types
- Aliases for types defined in the auto-generated bindings.
- util
- Utility functions and types.
- wrap_
conf
Structs§
- Client
Config - Client configuration.
- KWClient
- KWConsumer
- KWConsumer
Conf - KWProducer
- KWProducer
Conf - Statistics
- Overall statistics.
- Topic
Partition List - A structure to store and manipulate a list of topics and partitions with optional offsets.
Enums§
Traits§
- Admin
Client Ext - Client
Context - Client-level context.
- Into
Opaque - Converts Rust data to and from raw pointers.
- LogWrap
Ext - Message
- A generic representation of a Kafka message.
- Option
Ext