org.graylog2.inputs.kafka

Class KafkaInput

java.lang.Object

org.graylog2.plugin.inputs.MessageInput

org.graylog2.inputs.kafka.KafkaInput

All Implemented Interfaces:

Stoppable

Direct Known Subclasses:

RadioKafkaInput

public class KafkaInput
extends MessageInput

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaInput.Config
static class	KafkaInput.Descriptor
static interface	KafkaInput.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

Modifier	Constructor and Description
	KafkaInput(Configuration configuration, com.codahale.metrics.MetricRegistry metricRegistry, KafkaTransport.Factory transport, RadioMessageCodec.Factory codec, LocalMetricRegistry localRegistry, KafkaInput.Config config, KafkaInput.Descriptor descriptor, ServerStatus serverStatus)
protected	KafkaInput(com.codahale.metrics.MetricRegistry metricRegistry, Configuration configuration, KafkaTransport radioKafkaTransport, RadioMessageCodec radioMessageCodec, LocalMetricRegistry localRegistry, MessageInput.Config config, MessageInput.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

KafkaInput

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

KafkaInput

protected KafkaInput(com.codahale.metrics.MetricRegistry metricRegistry,
          Configuration configuration,
          KafkaTransport radioKafkaTransport,
          RadioMessageCodec radioMessageCodec,
          LocalMetricRegistry localRegistry,
          MessageInput.Config config,
          MessageInput.Descriptor descriptor,
          ServerStatus serverStatus)