object KafkaProducer{
 def send(eventContent: String): Unit = println(s"sending to Kafka: $eventContent")
}
object Monitor{
 def incrementCounter(counterName: String, tags: (String, String)): Unit = println(s"incrementing counter $counterName")
}
object Logger{
 def log(event: String): Unit = println(s"error: $event")
}
object S3_Client {
 def upload(eventContent: String): Unit = println(s"uploading event $eventContent to S3")
}