no otlp endpoint and fix build issues

Author: wlawt

Cargo.lock

@@ -101,7 +101,7 @@ async fn main() -> Result<()> {
             args.tracing_otlp_endpoint.clone(),
         )?;
     }
-    
+
     let consumer = create_kafka_consumer(&args.kafka_properties_file)?;
     consumer.subscribe(&[&args.kafka_topic])?;
 

crates/audit/src/bin/main.rs

@@ -1,7 +1,7 @@
 use anyhow::Context;
 use opentelemetry::trace::TracerProvider;
 use opentelemetry::{global, KeyValue};
-use opentelemetry_otlp::{SpanExporter, WithExportConfig};
+use opentelemetry_otlp::SpanExporter;
 use opentelemetry_sdk::{propagation::TraceContextPropagator, trace::SdkTracerProvider, Resource};
 use tracing_opentelemetry::OpenTelemetryLayer;
 use tracing_subscriber::{
@@ -13,13 +13,12 @@ use tracing_subscriber::{
 pub fn init_tracing(
     service_name: String,
     service_version: String,
-    otlp_endpoint: String,
+    _otlp_endpoint: String,
 ) -> anyhow::Result<()> {
     global::set_text_map_propagator(TraceContextPropagator::new());
 
     let otlp_exporter = SpanExporter::builder()
         .with_tonic()
-        .with_endpoint(otlp_endpoint)
         .build()
         .context("Failed to create OTLP exporter")?;
 

crates/common/src/lib.rs

@@ -35,3 +35,4 @@ op-revm.workspace = true
 revm-context-interface.workspace = true
 alloy-signer-local.workspace = true
 reth-optimism-evm.workspace = true
+tips-common.workspace = true

crates/ingress-rpc/Cargo.toml

@@ -58,6 +58,7 @@ struct Config {
         default_value = "10800"
     )]
     send_transaction_default_lifetime_seconds: u64,
+
     #[arg(long, env = "TIPS_INGRESS_TRACING_ENABLED", default_value = "false")]
     tracing_enabled: bool,
 

crates/ingress-rpc/src/main.rs

@@ -147,6 +147,7 @@ async fn main() -> Result<()> {
 
     let config = load_kafka_config_from_file(&args.kafka_properties_file)?;
     let kafka_producer: FutureProducer = config.create()?;
+
     if args.tracing_enabled {
         init_tracing(
             env!("CARGO_PKG_NAME").to_string(),
@@ -155,15 +156,6 @@ async fn main() -> Result<()> {
         )?;
     }
 
-    let mut config = ClientConfig::new();
-    config
-        .set("group.id", &args.kafka_group_id)
-        .set("bootstrap.servers", &args.kafka_brokers)
-        .set("auto.offset.reset", "earliest")
-        .set("enable.partition.eof", "false")
-        .set("session.timeout.ms", "6000")
-        .set("enable.auto.commit", "true");
-
     let publisher = KafkaBundleEventPublisher::new(kafka_producer, args.audit_topic.clone());
     let consumer = config.create()?;
 

crates/ingress-writer/src/main.rs

@@ -11,12 +11,10 @@ use rdkafka::ClientConfig;
 use rdkafka::producer::FutureProducer;
 use std::fs;
 use std::sync::Arc;
-use std::time::Duration;
-use tips_audit::{KafkaMempoolEventPublisher, MempoolEvent, MempoolEventPublisher};
+use tips_audit::KafkaBundleEventPublisher;
 use tips_common::init_tracing;
-use tips_datastore::{BundleDatastore, PostgresDatastore};
-use tokio::time::sleep;
-use tracing::{error, info, warn};
+use tips_datastore::PostgresDatastore;
+use tracing::{info, warn};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 use url::Url;
 
@@ -115,7 +113,7 @@ async fn main() -> Result<()> {
         init_tracing(
             env!("CARGO_PKG_NAME").to_string(),
             env!("CARGO_PKG_VERSION").to_string(),
-            args.tracing_otlp_endpoint,
+            args.tracing_otlp_endpoint.clone(),
         )?;
     }