storm.kafka
Class KafkaSpout
java.lang.Object
backtype.storm.topology.base.BaseComponent
backtype.storm.topology.base.BaseRichSpout
storm.kafka.KafkaSpout
- All Implemented Interfaces:
- ISpout, IComponent, IRichSpout, Serializable
public class KafkaSpout
- extends BaseRichSpout
- See Also:
- Serialized Form
Field Summary |
static org.slf4j.Logger |
LOG
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public static final org.slf4j.Logger LOG
KafkaSpout
public KafkaSpout(SpoutConfig spoutConf)
open
public void open(Map conf,
TopologyContext context,
SpoutOutputCollector collector)
close
public void close()
- Specified by:
close
in interface ISpout
- Overrides:
close
in class BaseRichSpout
nextTuple
public void nextTuple()
ack
public void ack(Object msgId)
- Specified by:
ack
in interface ISpout
- Overrides:
ack
in class BaseRichSpout
fail
public void fail(Object msgId)
- Specified by:
fail
in interface ISpout
- Overrides:
fail
in class BaseRichSpout
deactivate
public void deactivate()
- Specified by:
deactivate
in interface ISpout
- Overrides:
deactivate
in class BaseRichSpout
declareOutputFields
public void declareOutputFields(OutputFieldsDeclarer declarer)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.