I hereby claim:
- I am childe on github.
- I am rmself (https://keybase.io/rmself) on keybase.
- I have a public key ASCOeIXxeLvMJ_BGHu6uRItBseHcOV0Dss3lmB1TQIyBqQo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
/* Our own header, to be included before all standard system headers */ | |
#ifndef _APUE_H | |
#define _APUE_H | |
#if defined(SOLARIS) | |
#define _XOPEN_SOURCE 500 /* Single UNIX Specification, Version 2 for Solaris 9 */ | |
#define CMSG_LEN(x) _CMSG_DATA_ALIGN(sizeof(struct cmsghdr)+(x)) | |
#elif !defined(BSD) | |
#define _XOPEN_SOURCE 600 /* Single UNIX Specification, Version 3 */ |
package com.ctrip.ops.sysdev.outputs; | |
import com.ctrip.ops.sysdev.baseplugin.BaseOutput; | |
import com.ctrip.ops.sysdev.render.DateFormatter; | |
import com.ctrip.ops.sysdev.render.TemplateRender; | |
import org.apache.log4j.Logger; | |
import org.elasticsearch.action.DocWriteRequest; | |
import org.elasticsearch.action.bulk.BulkItemResponse; | |
import org.elasticsearch.action.bulk.BulkProcessor; | |
import org.elasticsearch.action.bulk.BulkRequest; |
topology: ops_hangout_dimg | |
inputs: | |
- Kafka: | |
codec: json | |
topic: logstash-opslinuxlog-nginx-dimg | |
spoutname: kafkaspout | |
consumer_settings: | |
group.id: logstash | |
zookeeper.connect: "10.8.84.74:2181" |