partitionline 0.1.0

Pure-Rust Apache Kafka client and protocol implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

pub mod acl;
pub mod admin;
pub mod api;
pub mod api_keys;
pub mod buf;
pub mod cgheartbeat;
pub mod epoch;
pub mod fetch;
pub mod group;
pub mod header;
pub mod idem;
pub mod oauth;
pub mod offsets;
pub mod oidc;
pub mod records;
pub mod sasl;
pub mod scram;
pub mod share;
pub mod txn;

pub use api::{
    decode_api_versions_handshake, decode_api_versions_response, decode_metadata_request,
    decode_metadata_request_topics, decode_metadata_response, decode_produce_request,
    decode_produce_response, encode_api_versions_request, encode_api_versions_response,
    encode_metadata_request, encode_metadata_request_topics,
    encode_metadata_request_topics_with_include_cluster_authorized_operations,
    encode_metadata_request_with, encode_metadata_response, encode_produce_request,
    encode_produce_response, negotiate_api_versions, ApiVersion, ApiVersionsResponse, Broker,
    FinalizedFeatureKey, MetadataRequestTopic, MetadataResponse, NodeEndpoint, PartitionMetadata,
    ProducePartitionData, ProducePartitionResponse, ProduceRecordError, ProduceTopicData,
    SupportedFeatureKey, TopicMetadata,
};
pub use api_keys::{
    pick_version, API_VERSIONS, CREATE_TOPICS, DELETE_TOPICS, DESCRIBE_CONFIGS, FETCH,
    FIND_COORDINATOR, HEARTBEAT, INIT_PRODUCER_ID, JOIN_GROUP, LEAVE_GROUP, LIST_OFFSETS, METADATA,
    OFFSET_COMMIT, OFFSET_FETCH, PRODUCE, SASL_AUTHENTICATE, SASL_HANDSHAKE, SYNC_GROUP,
};
pub use header::{
    decode_request_header, decode_response_header, encode_request_header, encode_response_header,
    request_header_version, response_header_size, response_header_version, RequestHeader,
};
pub use records::{
    Compression, ControlRecordType, EndTransactionMarker, Header, Record, RecordBatch, Records,
    TimestampType,
};