kafkit-client 0.1.6

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

use crate::producer::ProducerRuntimeEvent;

pub(super) fn producer_event_name(event: &ProducerRuntimeEvent) -> &'static str {
    match event {
        ProducerRuntimeEvent::WarmUp { .. } => "warm_up",
        ProducerRuntimeEvent::BeginTransaction { .. } => "begin_transaction",
        ProducerRuntimeEvent::InitTransactions { .. } => "init_transactions",
        ProducerRuntimeEvent::AppendRecord { .. } => "append_record",
        ProducerRuntimeEvent::Flush { .. } => "flush",
        ProducerRuntimeEvent::CommitTransaction { .. } => "commit_transaction",
        ProducerRuntimeEvent::AbortTransaction { .. } => "abort_transaction",
        ProducerRuntimeEvent::SendOffsetsToTransaction { .. } => "send_offsets_to_transaction",
        ProducerRuntimeEvent::Shutdown { .. } => "shutdown",
    }
}