pcvolkmer/bwhc-kafka-proxy
1
0
Fork 0
mirror of https://github.com/CCC-MF/bwhc-kafka-rest-proxy.git synced 2025-04-19 19:16:51 +00:00
Code Issues Activity

build: use tracing in debug mode

Browse Source
This commit is contained in:
Paul-Christian Volkmer 2024-03-08 14:44:18 +01:00
parent 9ef1072f3c
commit 4e47e19b12
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Cargo.toml
View File

@ -16,11 +16,22 @@ version = "1.6"
[dependencies.axum] [dependencies.axum]
version = "0.7" version = "0.7"
features = ["tracing"]
[dependencies.tracing-subscriber]
version = "0.3"
[dependencies.tracing]
version = "0.1"
[dependencies.tokio] [dependencies.tokio]
version = "1.36" version = "1.36"
features = ["rt-multi-thread"] features = ["rt-multi-thread"]
[dependencies.tower-http]
version = "0.5"
features = ["trace"]
[dependencies.serde] [dependencies.serde]
version = "1.0" version = "1.0"
features = ["derive"] features = ["derive"]

12
src/main.rs
View File

@ -14,6 +14,8 @@ use rdkafka::ClientConfig;
use rdkafka::message::{Header, OwnedHeaders}; use rdkafka::message::{Header, OwnedHeaders};
use rdkafka::producer::{FutureProducer, FutureRecord}; use rdkafka::producer::{FutureProducer, FutureRecord};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
#[cfg(debug_assertions)]
use tower_http::trace::TraceLayer;
use uuid::Uuid; use uuid::Uuid;
mod auth; mod auth;
@ -30,6 +32,13 @@ struct RecordKey {
async fn main() { async fn main() {
let _ = bcrypt_hashed_token(); let _ = bcrypt_hashed_token();
#[cfg(debug_assertions)]
{
tracing_subscriber::fmt()
.with_max_level(tracing::Level::DEBUG)
.init();
}
let boostrap_servers = env::var("KAFKA_BOOTSTRAP_SERVERS").unwrap_or("kafka:9094".into()); let boostrap_servers = env::var("KAFKA_BOOTSTRAP_SERVERS").unwrap_or("kafka:9094".into());
let producer: FutureProducer = ClientConfig::new() let producer: FutureProducer = ClientConfig::new()
@ -44,6 +53,9 @@ async fn main() {
.layer(Extension(producer)) .layer(Extension(producer))
.layer(from_fn(check_basic_auth)); .layer(from_fn(check_basic_auth));
#[cfg(debug_assertions)]
let app = app.layer(TraceLayer::new_for_http());
let listener = tokio::net::TcpListener::bind("0.0.0.0:8000").await.unwrap(); let listener = tokio::net::TcpListener::bind("0.0.0.0:8000").await.unwrap();
axum::serve(listener, app).await.unwrap(); axum::serve(listener, app).await.unwrap();
} }