ggtools

input {
    gelf {
        type => docker
        port => 12201
    }
}

filter {
    multiline {
        pattern => "^%{TIMESTAMP_ISO8601}"

rantav

package ...;

import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

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

import com.amazonaws.Request;

okcpt

package utils;

import java.util.zip.Checksum;

/**
 * User: punksa
 * Date: 13-10-11
 * Time: 下午10:33
 */

asmaier

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Properties;
import org.I0Itec.zkclient.ZkClient;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;