public static class KafkaInput.Config extends MessageInput.Config
codecConfig, transportConfig| Constructor and Description |
|---|
KafkaInput.Config(KafkaTransport.Factory transport,
RadioMessageCodec.Factory codec) |
@Inject public KafkaInput.Config(KafkaTransport.Factory transport, RadioMessageCodec.Factory codec)
Copyright © 2012-2015 Graylog, Inc.. All Rights Reserved.