修复Springboot下的表现

pom.xml

@@ -12,8 +12,20 @@
     </modules>
     <groupId>com.tuandai.log</groupId>
     <artifactId>slf4j-kafka</artifactId>
-    <version>1.7.5</version>
-
+    <version>1.0.1-SNAPSHOT</version>
+    <distributionManagement>
+        <snapshotRepository>
+            <id>td-snapshot</id>
+            <name>User Porject Snapshot</name>
+            <url>http://nexus.tuandai.com/repository/maven-snapshots/</url>
+            <uniqueVersion>true</uniqueVersion>
+        </snapshotRepository>
+        <repository>
+            <id>td-release</id>
+            <name>User Porject Release</name>
+            <url>http://nexus.tuandai.com/repository/maven-releases/</url>
+        </repository>
+    </distributionManagement>
     <build>
         <plugins>
             <plugin>

slf4j-kafka-over-log4j12/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>slf4j-kafka</artifactId>
         <groupId>com.tuandai.log</groupId>
-        <version>1.7.5</version>
+        <version>1.0.1-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -43,7 +43,7 @@
         <dependency>
             <groupId>com.tuandai.log</groupId>
             <artifactId>slf4j-kafka-producer</artifactId>
-            <version>1.7.5</version>
+            <version>1.0.1-SNAPSHOT</version>
         </dependency>
     </dependencies>
 

slf4j-kafka-over-log4j12/src/main/java/com/tuandai/log/log4j12/converter/EncodedMessagePatternConverter.java

@@ -39,6 +39,9 @@ public class EncodedMessagePatternConverter extends LoggingEventPatternConverter
      * {@inheritDoc}
      */
     public void format(final LoggingEvent event, final StringBuffer toAppendTo) {
-        toAppendTo.append(event.getRenderedMessage().replace("\"","\\\"").replace("'","\\'"));
+        toAppendTo.append(event.getRenderedMessage()
+                .replaceAll("\"","\\\"")
+                .replaceAll("'","\\'")
+                .replaceAll("\n","\\n"));
     }
 }

slf4j-kafka-over-logback/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>slf4j-kafka</artifactId>
         <groupId>com.tuandai.log</groupId>
-        <version>1.7.5</version>
+        <version>1.0.1-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -35,7 +35,7 @@
         <dependency>
             <groupId>com.tuandai.log</groupId>
             <artifactId>slf4j-kafka-producer</artifactId>
-            <version>1.7.5</version>
+            <version>1.0.1-SNAPSHOT</version>
         </dependency>
     </dependencies>
     <build>

slf4j-kafka-over-logback/src/main/java/com/tuandai/log/logback/converter/EncodedMessageConverter.java

@@ -12,6 +12,9 @@ import com.tuandai.log.kafka.config.Slf4jKafkaContext;
 public class EncodedMessageConverter extends ClassicConverter {
     @Override
     public String convert(ILoggingEvent event) {
-        return event.getFormattedMessage().replace("\"","\\\"").replace("'","\\'");
+        String s = event.getFormattedMessage().replaceAll("\"", "\\\"")
+                .replaceAll("'", "\\'")
+                .replaceAll("\n", "\\n");
+        return s;
     }
 }

slf4j-kafka-over-logback/src/main/resources/logback.xml

@@ -9,7 +9,7 @@
         </encoder>
     </appender>
 
-    <property name="KAFKA_PATTERN" value='{"@timestamp": "%d{yyyy-MM-dd"T"HH:mm:ss.SSS"Z"}","beat": { "hostname": "${HOSTNAME}","name": "%sys_user", "version": "5.2.2" }, "fields": { "app_id": "%app_id" }, "input_type": "log", "message": "%d{yyyy-MM-dd HH:mm:ss.SSS} -%5p %pid --- [%15.15t] %-40.40logger{39} : %encode_message%n", "offset": 0, "source": "", "type": "log" }' />
+    <property name="KAFKA_PATTERN" value='{"@timestamp": "%d{yyyy-MM-dd HH:mm:ss.SSS}","beat": { "hostname": "${HOSTNAME}","name": "%sys_user", "version": "5.2.2" }, "fields": { "app_id": "%app_id" }, "input_type": "log", "message": "%d{yyyy-MM-dd HH:mm:ss.SSS} -%5p %pid --- [%15.15t] %-40.40logger{39} : %encode_message%n", "offset": 0, "source": "", "type": "log" }' />
     <appender name="KAFKA" class="com.tuandai.log.logback.appender.KafkaConcurrentAppender">
         <encoder class="com.tuandai.log.logback.layout.ExtendedPatternLayoutEncoder">
             <pattern>${KAFKA_PATTERN}</pattern>

slf4j-kafka-over-logback/src/test/resources/logback.xml

@@ -12,7 +12,7 @@
         </encoder>
     </appender>
 
-    <property name="KAFKA_PATTERN" value="{'@timestamp': '%d{yyyy-MM-ddTHH:mm:ss.SSSZ}','beat': { 'hostname': '${HOSTNAME}','name': '%sys_user', 'version': '5.2.2' }, 'fields': { 'app_id': '%app_id' }, 'input_type': 'log', 'message': '${LOG_PATTERN}', 'offset': 0, 'source': '', 'type': 'log' }" />
+    <property name="KAFKA_PATTERN" value="{'@timestamp': '%d{yyyy-MM-dd HH:mm:ss.SSS}','beat': { 'hostname': '${HOSTNAME}','name': '%sys_user', 'version': '5.2.2' }, 'fields': { 'app_id': '%app_id' }, 'input_type': 'log', 'message': '${LOG_PATTERN}', 'offset': 0, 'source': '', 'type': 'log' }" />
     <appender name="KAFKA" class="com.tuandai.log.logback.appender.KafkaAppender">
         <encoder class="com.tuandai.log.logback.layout.ExtendedPatternLayoutEncoder">
             <pattern>${KAFKA_PATTERN}</pattern>

slf4j-kafka-producer/pom.xml

@@ -5,7 +5,8 @@
     <parent>
         <artifactId>slf4j-kafka</artifactId>
         <groupId>com.tuandai.log</groupId>
-        <version>1.7.5</version>
+        <version>1.0.1-SNAPSHOT</version>
+
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

slf4j-kafka-producer/src/main/java/com/tuandai/log/kafka/config/Slf4jKafkaConfigSimpleFactory.java

@@ -34,7 +34,7 @@ public class Slf4jKafkaConfigSimpleFactory {
      * @return 配置文件URL
      */
     private URL getConfigFileUrl(){
-        ClassLoader myClassLoader = Slf4jKafkaConfigSimpleFactory.class.getClassLoader();
+        ClassLoader myClassLoader = Thread.currentThread().getContextClassLoader();
         try {
             return myClassLoader.getResource(DEFAULT_CONFIGURATION_FILE);
         } catch (Throwable t) {