org.graylog2.inputs.transports

Class RadioKafkaTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.ThrottleableTransport

org.graylog2.inputs.transports.KafkaTransport

org.graylog2.inputs.transports.RadioKafkaTransport

All Implemented Interfaces:

Transport

public class RadioKafkaTransport
extends KafkaTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RadioKafkaTransport.Config
static interface	RadioKafkaTransport.Factory

Field Summary

Fields inherited from class org.graylog2.inputs.transports.KafkaTransport

CK_FETCH_MIN_BYTES, CK_FETCH_WAIT_MAX, CK_THREADS, CK_TOPIC_FILTER, CK_ZOOKEEPER, GROUP_ID

Fields inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

CK_THROTTLING_ALLOWED

Constructor Summary

Constructors

Constructor and Description
RadioKafkaTransport(Configuration configuration, LocalMetricRegistry localRegistry, NodeId nodeId, com.google.common.eventbus.EventBus serverEventBus, ServerStatus serverStatus, ScheduledExecutorService scheduler)

Method Summary

Methods inherited from class org.graylog2.inputs.transports.KafkaTransport

doLaunch, doStop, getMetricSet, lifecycleStateChange, setMessageAggregator

Methods inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

blockUntilUnthrottled, determineIfThrottled, isThrottled, launch, stop, updateThrottleState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RadioKafkaTransport

public RadioKafkaTransport(Configuration configuration,
                   LocalMetricRegistry localRegistry,
                   NodeId nodeId,
                   com.google.common.eventbus.EventBus serverEventBus,
                   ServerStatus serverStatus,
                   @Named(value="daemonScheduler")
                   ScheduledExecutorService scheduler)