kafkit-client 0.1.0

Kafka 4.0+ pure Rust client.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

mod protocol;
mod state;

pub use protocol::{
    TransactionFailureDisposition, build_find_coordinator_request,
    build_group_find_coordinator_request, build_txn_offset_commit_request,
    classify_transactional_error, ensure_transaction_v2_feature, find_coordinator_error,
    parse_find_coordinator_response, validate_group_metadata,
};
pub use state::{
    ProducerIdentity, TransactionCoordinator, TransactionCoordinatorConnection, TransactionManager,
    TransactionResult,
};