Skip to content

Commit 1055c81

Browse files
add import
1 parent 53b7462 commit 1055c81

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/connectors/kafka/processor.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,13 +24,13 @@ use std::collections::HashMap;
2424
use std::sync::Arc;
2525
use tokio_stream::wrappers::ReceiverStream;
2626
use tracing::{debug, error};
27-
2827
use crate::{
2928
connectors::common::processor::Processor,
3029
event::{
3130
Event as ParseableEvent, USER_AGENT_KEY,
3231
format::{EventFormat, LogSourceEntry, json},
3332
},
33+
handlers::TelemetryType,
3434
parseable::PARSEABLE,
3535
storage::StreamType,
3636
};

0 commit comments

Comments
 (0)