public static interface KafkaInput.Factory extends MessageInput.Factory<KafkaInput>
| Modifier and Type | Method and Description |
|---|---|
KafkaInput |
create(Configuration configuration) |
KafkaInput.Config |
getConfig() |
KafkaInput.Descriptor |
getDescriptor() |
KafkaInput create(Configuration configuration)
create in interface MessageInput.Factory<KafkaInput>KafkaInput.Config getConfig()
getConfig in interface MessageInput.Factory<KafkaInput>KafkaInput.Descriptor getDescriptor()
getDescriptor in interface MessageInput.Factory<KafkaInput>Copyright © 2012-2015 Graylog, Inc.. All Rights Reserved.