Wso2carbon регистрирует 2 logstash, используя входной плагин tcp, без filebeat - PullRequest
Новая
       7

Wso2carbon регистрирует 2 logstash, используя входной плагин tcp, без filebeat

0 голосов
/ 07 июня 2018

Я пытаюсь передать логи wso2carbon в elk, используя входной плагин tcp

моя конфигурация для файла wso2 log4jproperties.

#TCP logger pattern log4j.appender.tcp=org.apache.log4j.net.SocketAppender
log4j.appender.tcp.layout=org.wso2.carbon.utils.logging.TenantAwarePatternLayout
# ConversionPattern will be overridden by the configuration setting in the DB log4j.appender.tcp.layout.ConversionPattern=TID: [%T] [%S] [%d] %P%5p {%c} - %x %m {%c}%n log4j.appender.tcp.layout.TenantPattern=%U%@%D [%T] [%S] log4j.appender.tcp.Port=6000 log4j.appender.tcp.RemoteHost=localhost log4j.appender.tcp.ReconnectionDelay=10000 log4j.appender.tcp.threshold=DEBUG log4j.appender.tcp.Application=wso2carbon

Конфигурация для logstash.conf 

input {     tcp {       mode => server      port => 6000        add_field =>            type
=> "wso2carbon"
        }   } }

Я успешно получаю сообщения от wso2carbon.но сообщение вроде зашифрованного формата.как показано ниже. 

{
       "message" => "threadNameq\\u0000~\\u0000\\u0001L\\u0000\\rthrowableInfot\\u0000+Lorg/apache/log4j/spi/ThrowableInformation;xp\\u0000\\u0000\\u0000\\u0000\\u0001c\\xD9\\xC9\\xF3,t\\u0000Forg.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorkerpsr\\u0000\\u0013java.util.Hashtable\\u0013\\xBB\\u000F%!J\\xE4\\xB8\\u0003\\u0000\\u0002F\\u0000",
          "host" => "127.0.0.1",
      "@version" => "1",
          "port" => 59581,
          "type" => "wso2carbon",
    "@timestamp" => 2018-06-07T10:28:01.179Z,
          "tags" => [
        [0] "_grokparsefailure"
    ] }

пожалуйста, дайте мне знать, как расшифровать это.

1 Ответ

0 голосов
/ 08 июня 2018

Это потому, что вы не указали кодек , который будет использоваться для декодирования вашего сообщения при получении, кодеки - это удобный метод для декодирования ваших данных перед их вводом, без необходимости отдельного фильтра вваш конвейер Logstash.

добавьте это в ваш ввод под mode => server, 

codec => json

Дайте мне знать, если это поможет

...