kafrust 0.3.1

A pure Rust Kafka client with no librdkafka or C client binding dependency.
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

#![doc = include_str!("../README.md")]
#![forbid(unsafe_code)]
#![warn(missing_docs)]

/// Kafka administration API.
pub mod admin;
/// Low-level Kafka request client.
pub mod client;
/// Shared connection configuration.
pub mod config;
/// Direct topic/partition consumer API.
pub mod consumer;
/// Error and result types.
pub mod error;
/// Classic consumer group alpha API.
pub mod group;
/// Lock-free client request metrics.
pub mod metrics;
/// Producer API.
pub mod producer;
/// KIP-932 share-group consumer API.
pub mod share_consumer;
/// Kafka Streams group membership and heartbeat API.
pub mod streams;
/// KIP-714 client telemetry API.
pub mod telemetry;

mod scram;

pub use admin::{
    AclBinding, AclFilter, AclOperation, AclPatternType, AclPermissionType, AclResourceType,
    AddRaftVoterOptions, AdminClient, AlterClientQuotaEntryResult, AlterClientQuotasResult,
    AlterConfigResourceResult, AlterConfigsOptions, AlterConfigsResult,
    AlterConsumerGroupOffsetsPartitionResult, AlterConsumerGroupOffsetsResult,
    AlterConsumerGroupOffsetsTopicResult, AlterPartitionReassignmentResult,
    AlterPartitionReassignmentTopicResult, AlterPartitionReassignmentsResult,
    AlterReplicaLogDirsPartitionResult, AlterReplicaLogDirsResult, AlterReplicaLogDirsTopicResult,
    AlterScramCredentialResult, AlterShareGroupOffsetsPartitionResult,
    AlterShareGroupOffsetsResult, AlterShareGroupOffsetsTopicResult,
    AlterUserScramCredentialsResult, BrokerDescription, ClientQuotaAlteration, ClientQuotaEntity,
    ClientQuotaEntityComponent, ClientQuotaFilter, ClientQuotaFilterComponent,
    ClientQuotaMatchType, ClientQuotaOperation, ClientQuotaValue, ClusterDescription,
    ConfigAlterOperation, ConfigAlterOperationKind, ConfigEntry, ConfigResourceResult,
    ConfigResourceType, ConfigSource, ConfigSynonym, ConsumerGroupDescription, ConsumerGroupMember,
    ConsumerGroupOffset, ConsumerGroupOffsetDelete, ConsumerGroupOffsetPartitionResult,
    ConsumerGroupOffsetQuery, ConsumerGroupOffsetTopicResult, CreateAclsEntryResult,
    CreateAclsResult, CreateDelegationTokenOptions, CreatePartitionsOptions,
    CreatePartitionsResult, CreatePartitionsTopicResult, CreateTopicResult, CreateTopicsOptions,
    CreateTopicsResult, CreatedDelegationToken, DelegationTokenOperationResult,
    DelegationTokenPrincipal, DeleteAclsFilterResult, DeleteAclsResult,
    DeleteConsumerGroupOffsetsPartitionResult, DeleteConsumerGroupOffsetsResult,
    DeleteConsumerGroupOffsetsTopicResult, DeleteConsumerGroupResult, DeleteRecordsOptions,
    DeleteRecordsPartition, DeleteRecordsPartitionResult, DeleteRecordsResult, DeleteRecordsTopic,
    DeleteRecordsTopicResult, DeleteShareGroupOffsetsResult, DeleteShareGroupOffsetsTopicResult,
    DeleteShareGroupResult, DeleteTopicResult, DeleteTopicsOptions, DeleteTopicsResult,
    DeletedAclResult, DescribeAclsResult, DescribeClientQuotasResult, DescribeClusterEndpointType,
    DescribeClusterOptions, DescribeConfigsOptions, DescribeConfigsResult,
    DescribeDelegationTokensResult, DescribeLogDirsBrokerResult, DescribeProducersActiveProducer,
    DescribeProducersPartitionResult, DescribeProducersResult, DescribeProducersTopic,
    DescribeProducersTopicResult, DescribeQuorumListener, DescribeQuorumNode,
    DescribeQuorumPartitionResult, DescribeQuorumReplicaState, DescribeQuorumResult,
    DescribeQuorumTopic, DescribeQuorumTopicResult, DescribeTopicPartitionsCursor,
    DescribeTopicPartitionsOptions, DescribeTopicPartitionsPartition,
    DescribeTopicPartitionsResult, DescribeTopicPartitionsTopic, DescribeTransactionsResult,
    DescribeUserScramCredentialsResult, DescribedDelegationTokenResult, ElectLeadersOptions,
    ElectLeadersPartitionResult, ElectLeadersResult, ElectLeadersTopicResult, ElectionType,
    FeatureMetadata, FeatureUpdate, FeatureUpdateResult, FeatureUpgradeType, FinalizedFeature,
    GroupListing, LeaderElection, ListConfigResourcesOptions, ListConfigResourcesResult,
    ListConsumerGroupOffsetsResult, ListGroupsOptions, ListPartitionReassignmentsResult,
    ListShareGroupOffsetsResult, ListTransactionsOptions, ListTransactionsResult,
    ListedConfigResource, ListedTransaction, LogDirTopic, LogDirectoryPartitionResult,
    LogDirectoryResult, LogDirectoryTopicResult, ModernConsumerGroupAssignment,
    ModernConsumerGroupDescription, ModernConsumerGroupMember, ModernConsumerGroupTopicPartitions,
    NewPartitions, NewTopic, OngoingPartitionReassignment, OngoingPartitionReassignmentTopic,
    PartitionReassignment, PartitionReassignmentOptions, PartitionReassignmentPartition,
    PartitionReassignmentQuery, RaftVoterListener, RaftVoterResult,
    ReadShareGroupStatePartitionResult, ReadShareGroupStateResult,
    ReadShareGroupStateSummaryPartitionResult, ReadShareGroupStateSummaryResult,
    ReadShareGroupStateSummaryTopicResult, ReadShareGroupStateTopicResult, RemoveRaftVoterOptions,
    ReplicaLogDirAssignment, ScramCredentialDeletion, ScramCredentialInfo,
    ScramCredentialMechanism, ScramCredentialUpsertion, ScramUserCredentials, ShareGroupAssignment,
    ShareGroupDescription, ShareGroupMember, ShareGroupOffset, ShareGroupOffsetPartitionResult,
    ShareGroupOffsetQuery, ShareGroupOffsetTopicResult, ShareGroupStateBatch,
    ShareGroupStateDeleteTopic, ShareGroupStateInitializePartition, ShareGroupStateInitializeTopic,
    ShareGroupStatePartitionResult, ShareGroupStateReadPartition, ShareGroupStateReadTopic,
    ShareGroupStateResult, ShareGroupStateTopicResult, ShareGroupStateWritePartition,
    ShareGroupStateWriteTopic, ShareGroupTopicPartitions, StreamsGroupAssignment,
    StreamsGroupDescription, StreamsGroupEndpoint, StreamsGroupKeyValue, StreamsGroupMember,
    StreamsGroupSubtopology, StreamsGroupTask, StreamsGroupTaskOffset, StreamsGroupTopic,
    StreamsGroupTopicConfig, StreamsGroupTopology, SupportedFeature, TopicConfigAlteration,
    TopicConfigResource, TopicConfigUpdate, TopicConfigUpdateEntry, TopicListing,
    TransactionDescription, TransactionDescriptionTopic, UnregisterBrokerResult,
    UpdateFeaturesOptions, UpdateFeaturesResult,
};
pub use client::Client;
pub use config::{
    ClientConfig, OAuthBearerTokenFuture, OAuthBearerTokenProvider, SaslCredentials, SaslMechanism,
    SecurityProtocol,
};
pub use consumer::{
    Consumer, ConsumerAssignment, ConsumerConfig, ConsumerPartitionQueue, ConsumerRecord,
    ConsumerRecordHeader, IsolationLevel, LeaderEpochOffset, OffsetResetPolicy,
    PartitionWatermarks,
};
pub use error::{BrokerErrorKind, Error, Result};
pub use group::{
    ConsumerGroup, ConsumerGroupAssignmentStrategy, ConsumerGroupCommitWorker, ConsumerGroupConfig,
    ConsumerGroupHeartbeat, ConsumerGroupMetadata, ConsumerGroupProtocol, RebalanceEvent,
    RebalanceListener, RebalancePhase,
};
pub use kafrust_protocol as protocol;
pub use metrics::{ClientMetrics, ClientMetricsSnapshot};
pub use producer::{
    Acks, BufferedProducer, BufferedProducerHandle, Compression, Header, Partitioner,
    ProducerBatchFailure, ProducerBatchRecordOutcome, ProducerBatchReport, ProducerConfig,
    ProducerDelivery, ProducerRecord, RecordMetadata, TransactionStatus,
};
pub use share_consumer::{
    ShareAcknowledgementMode, ShareAcknowledgementType, ShareAcquireMode, ShareConsumer,
    ShareConsumerConfig, ShareConsumerHeartbeat, ShareRecord,
};
pub use streams::{StreamsGroupConfig, StreamsGroupSession, StreamsGroupSessionAssignment};
#[cfg(feature = "otlp")]
pub use telemetry::ClientMetricsTelemetryProvider;
pub use telemetry::{
    TelemetryClient, TelemetryConfig, TelemetryMetricsProvider, TelemetryPushSummary,
    TelemetrySubscription,
};

/// Returns the crate version compiled into this build.
pub fn version() -> &'static str {
    env!("CARGO_PKG_VERSION")
}

#[cfg(test)]
mod tests {
    #[test]
    fn exposes_crate_version() {
        assert_eq!(crate::version(), env!("CARGO_PKG_VERSION"));
    }
}