diff --git a/pom.xml b/pom.xml
index ae45bec..c8177df 100644
--- a/pom.xml
+++ b/pom.xml
@@ -23,6 +23,12 @@
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>
+			<exclusions>
+				<exclusion>
+					<groupId>org.springframework.boot</groupId>
+					<artifactId>spring-boot-starter-logging</artifactId>
+				</exclusion>
+			</exclusions>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
@@ -75,7 +81,7 @@
 			<artifactId>jaxb-impl</artifactId>
 			<version>2.2.11</version>
 		</dependency>
-		
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>
@@ -98,7 +104,6 @@
 			<version>1.0</version>
 			<scope>compile</scope>
 		</dependency>
-
 	</dependencies>
 
 	<build>
diff --git a/src/main/java/com/uci/inbound/Inbound.java b/src/main/java/com/uci/inbound/Inbound.java
index 28792d9..7370a3e 100644
--- a/src/main/java/com/uci/inbound/Inbound.java
+++ b/src/main/java/com/uci/inbound/Inbound.java
@@ -10,8 +10,6 @@
 import org.springframework.data.cassandra.repository.config.EnableReactiveCassandraRepositories;
 import org.springframework.kafka.annotation.EnableKafka;
 
-import com.uci.dao.service.HealthService;
-
 @EnableKafka
 @EnableReactiveCassandraRepositories("com.uci.dao")
 @EntityScan("com.uci.dao")
@@ -24,7 +22,7 @@
 @SpringBootApplication
 @ComponentScan(basePackages = {"com.uci.inbound", "com.uci.adapter", "com.uci.utils"})
 public class Inbound {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws InterruptedException {
         SpringApplication.run(Inbound.class, args);
     }
 }
\ No newline at end of file
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index d7c0d01..c451228 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -34,6 +34,10 @@ fusionauth.url = ${FUSIONAUTH_URL}
 fusionauth.key = ${FUSIONAUTH_KEY}
 
 
+# log4j2 log topic config
+kafka.logs.topic=${KAFKA_LOGS_TOPIC}
+
+log4j2.contextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector
 
 
 
diff --git a/src/main/resources/log4j2.xml b/src/main/resources/log4j2.xml
new file mode 100644
index 0000000..61e2c0a
--- /dev/null
+++ b/src/main/resources/log4j2.xml
@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration packages="com.uci.inbound" status="warn"
+	name="spring-boot-kafka-log">
+	<Properties>
+		<Property name="kafka.topic">${env:KAFKA_LOGS_TOPIC}</Property>
+		<Property name="kafka.bootstrap.servers">${env:BOOTSTRAP_SERVERS}</Property>
+	</Properties>
+	<Appenders>
+		<customKafka name="KafkaLogAppender" topic="${kafka.topic}" syncSend="false">
+			<CustomLogLayout />
+			<Property name="bootstrap.servers">${kafka.bootstrap.servers}</Property>
+		</customKafka>
+
+		<Console name="stdout" target="SYSTEM_OUT">
+			<PatternLayout
+				pattern="%d{HH:mm:ss.SSS} stdout %highlight(%-5p) [%-7t] %F:%L - %m%n" />
+		</Console>
+
+		<Console name="stderr" target="SYSTEM_OUT">
+			<PatternLayout
+				pattern="%d{HH:mm:ss.SSS} stderr %highlight(%-5p) [%-7t] %F:%L - %m%n" />
+		</Console>
+
+	</Appenders>
+	<Loggers>
+		<Root level="info">
+			<AppenderRef ref="KafkaLogAppender" />
+			<AppenderRef ref="stdout" />
+			<AppenderRef ref="stderr" />
+		</Root>
+		<Logger name="org.apache.kafka" level="WARN" />
+		<!-- <Logger name="LOGGER_WITH_JSON_LAYOUT" level="INFO" additivity="false"> 
+			<AppendRef ref="KafkaLogAppender" /> </Logger> -->
+	</Loggers>
+</Configuration>
\ No newline at end of file