Skip to content

Instantly share code, notes, and snippets.

Keybase proof

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:

@childe
childe / apue.h
Created June 27, 2017 04:12 — forked from Batou99/apue.h
apue.h
/* 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"