Logs à envoyer de l'application java à logstash

Question

J'essaie de pousser mes logs de l'application java vers logstash sur le port 4512. Mais, quand je lance logstash, je vois que les logs sur logstash sont vus avec des caractères indésirables (comme le montre avec extrait ci-dessous). Quelqu'un peut-il suggérer comment gérer la fin de l'application pour que l'application java et le logstash puissent interagir au besoin?

package com.logging.messages.Messager; 

import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 

public class SockerLogger { 
    public static void main(String[] args) { 
     Logger log = LoggerFactory.getLogger(SockerLogger.class); 
     log.info("Info"); 
     log.debug("DEBUG"); 
    } 
} 

log4j.properties d'application java:

log4j.rootLogger=INFO, server 
log4j.appender.server=org.apache.log4j.net.SocketAppender 
log4j.appender.server.Port=4512 
log4j.appender.server.RemoteHost=localhost 
log4j.appender.server.ReconnectionDelay=10000 
log4j.appender.server.layout.ConversionPattern={"debug_level":"%p","debug_timestamp":"%d{ISO8601}","debug_thread":"%t","debug_file":"%F", "debug_line":"%L","debug_message":"%m"}%n 

fichier propriétés logstash/conf:

# Specifying Input Host and Port number for Retriveing Application Log Messages 

input { 
    tcp { 
    port => "4512" 
# type => "log" 
    codec => "json" 
} 
} 

#filter { 
# grok { 
#  match => [ "message" => "_@timestamp","yyyy-MM-dd HH:mm:ss,SSS" ] 
# } 
#} 


# Pushing Log Messages from Logstash to Elastic Search 

output { 
# elasticsearch { 
#  hosts => ["localhost:9200"] 
#  index => "logshub" 
# } 
stdout { codec => plain } 
} 

dépendances pom.xml:

<dependencies> 
    <!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-core --> 
    <dependency> 
     <groupId>org.apache.logging.log4j</groupId> 
     <artifactId>log4j-core</artifactId> 
     <version>2.9.0</version> 
    </dependency> 

    <dependency> 
     <groupId>org.slf4j</groupId> 
     <artifactId>slf4j-api</artifactId> 
     <version>1.7.25</version> 
    </dependency> 
    <dependency> 
     <groupId>org.slf4j</groupId> 
     <artifactId>slf4j-simple</artifactId> 
     <version>1.7.25</version> 
     <scope>test</scope> 
    </dependency> 
    <dependency> 
     <groupId>org.slf4j</groupId> 
     <artifactId>slf4j-log4j12</artifactId> 
     <version>1.7.25</version> 
    </dependency> 
</dependencies> 

sortie de la console Logstash

[2017-09-20T18:29:59,436][WARN ][logstash.codecs.jsonlines] JSON parse error, original data now in message field {:error=>#<LogStash::Json::ParserError: Unrecognized token 'ZmdcCopyLookupRequiredZndcLookupRequiredJ': was expecting ('true', 'false' or 'null') 
at [Source: ZmdcCopyLookupRequiredZndcLookupRequiredJ timeStampL 
categoryNametLjava/lang/String;L 
locationInfot#Lorg/apache/log4j/spi/LocationInfo;LmdcCopytLjava/util/Hashtable;Lndcq~LrenderedMessageq~L; line: 1, column: 47]>, :data=>"Z\u0000\u0015mdcCopyLookupRequiredZ\u0000\u0011ndcLookupRequiredJ\u0000\ttimeStampL\u0000\fcategoryNamet\u0000\u0012Ljava/lang/String;L\u0000\flocationInfot\u0000#Lorg/apache/log4j/spi/LocationInfo;L\u0000\amdcCopyt\u0000\u0015Ljava/util/Hashtable;L\u0000\u0003ndcq\u0000~\u0000\u0001L\u0000\u000FrenderedMessageq\u0000~\u0000\u0001L\u0000"} 
2017-09-20T22:29:59.434Z 127.0.0.1 \xAC\xED\u0000\u0005sr\u0000!org.apache.log4j.spi.LoggingEvent\xF3\xF2\xB9#t\v\xB5?\u0003\u00002017-09-20T22:29:59.455Z 127.0.0.1 ZmdcCopyLookupRequiredZndcLookupRequiredJ timeStampL 
categoryNametLjava/lang/String;L 
locationInfot#Lorg/apache/log4j/spi/LocationInfo;LmdcCopytLjava/util/Hashtable;Lndcq~LrenderedMessageq~L^C[2017-09-20T18:30:17,549][WARN ][logstash.runner   ] SIGINT received. Shutting down the agent. 
[2017-09-20T18:30:17,559][WARN ][logstash.agent   ] stopping pipeline {:id=>"main"} 

Answer 1

Comme les log4j API doc états:

SocketAppenders ne pas utiliser une mise en page. Ils expédient un objet LoggingEvent sérialisé au côté serveur. Logstash à l'autre extrémité de la socket s'attend à recevoir des messages en fonction du codec utilisé.

Pour autant que je sache, il n'est pas prêt à utiliser Appender à cet effet sur Java ni un codec approprié sur le côté logdash.