org.graylog2.inputs.radio

Class RadioKafkaInput

java.lang.Object

org.graylog2.plugin.inputs.MessageInput

org.graylog2.inputs.kafka.KafkaInput

org.graylog2.inputs.radio.RadioKafkaInput

All Implemented Interfaces:

Stoppable

public class RadioKafkaInput
extends KafkaInput

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RadioKafkaInput.Config
static class	RadioKafkaInput.Descriptor
static interface	RadioKafkaInput.Factory

Field Summary

Fields inherited from class org.graylog2.plugin.inputs.MessageInput

configuration, contentPack, createdAt, creatorUserId, FIELD_ATTRIBUTES, FIELD_CONFIGURATION, FIELD_CONTENT_PACK, FIELD_CREATED_AT, FIELD_CREATOR_USER_ID, FIELD_GLOBAL, FIELD_ID, FIELD_NAME, FIELD_NODE_ID, FIELD_RADIO_ID, FIELD_STARTED_AT, FIELD_STATIC_FIELDS, FIELD_TITLE, FIELD_TYPE, global, inputBuffer, persistId, title

Constructor Summary

Constructors

Constructor and Description
RadioKafkaInput(Configuration configuration, com.codahale.metrics.MetricRegistry metricRegistry, RadioKafkaTransport.Factory transport, RadioMessageCodec.Factory codec, LocalMetricRegistry localRegistry, RadioKafkaInput.Config config, RadioKafkaInput.Descriptor descriptor, ServerStatus serverStatus)

Method Summary

Methods inherited from class org.graylog2.plugin.inputs.MessageInput

addStaticField, addStaticFields, asMap, asMapMasked, checkConfiguration, equals, getAttributesWithMaskedPasswords, getCodec, getConfiguration, getContentPack, getCreatedAt, getCreatorUserId, getDefaultRecvBufferSize, getDescriptor, getId, getName, getNodeId, getPersistId, getRequestedConfiguration, getStaticFields, getTitle, getType, getUniqueReadableId, hashCode, initialize, isExclusive, isGlobal, launch, processRawMessage, setContentPack, setCreatedAt, setCreatorUserId, setDefaultRecvBufferSize, setGlobal, setNodeId, setPersistId, setTitle, stop, terminate, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RadioKafkaInput

public RadioKafkaInput(Configuration configuration,
               com.codahale.metrics.MetricRegistry metricRegistry,
               RadioKafkaTransport.Factory transport,
               RadioMessageCodec.Factory codec,
               LocalMetricRegistry localRegistry,
               RadioKafkaInput.Config config,
               RadioKafkaInput.Descriptor descriptor,
               ServerStatus serverStatus)