Receivers

loghub.receivers.Beats

It's used to receive events from Elastic's Beats.

beans:

• clientInactivityTimeout
• maxPayloadSize

loghub.receivers.Http

• port
• host

loghub.receivers.Kafka

A Apache Kafka consumer that extracts events from a Kafka cluster and inject it for processing. If headers are present, the are injected in an headers attribute.

• brokers, an array of hostname(:port) ; port is optional.
• port, the default port to connect, defautl to 9092.
• topic, the topic to subscribe ;
• group, the group that subscriber is part of, default to loghub.
• keyDeserializer, a class that implements Interface Deserializer.

loghub.receivers.SnmpTrap

• port
• host
• port

loghub.receivers.TcpLinesStream

• charset
• field
• maxLenght

loghub.receivers.Udp

• bufferSize

loghub.receivers.ZMQ

• hwm
• listen
• method
• type