storm.kafka
Class KafkaSpout

java.lang.Object
  extended by backtype.storm.topology.base.BaseComponent
      extended by backtype.storm.topology.base.BaseRichSpout
          extended by storm.kafka.KafkaSpout
All Implemented Interfaces:
ISpout, IComponent, IRichSpout, Serializable

public class KafkaSpout
extends BaseRichSpout

See Also:
Serialized Form

Nested Class Summary
static class KafkaSpout.MessageAndRealOffset
           
 
Field Summary
static org.slf4j.Logger LOG
           
 
Constructor Summary
KafkaSpout(SpoutConfig spoutConf)
           
 
Method Summary
 void ack(Object msgId)
           
 void close()
           
 void deactivate()
           
 void declareOutputFields(OutputFieldsDeclarer declarer)
           
 void fail(Object msgId)
           
 void nextTuple()
           
 void open(Map conf, TopologyContext context, SpoutOutputCollector collector)
           
 
Methods inherited from class backtype.storm.topology.base.BaseRichSpout
activate
 
Methods inherited from class backtype.storm.topology.base.BaseComponent
getComponentConfiguration
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface backtype.storm.topology.IComponent
getComponentConfiguration
 

Field Detail

LOG

public static final org.slf4j.Logger LOG
Constructor Detail

KafkaSpout

public KafkaSpout(SpoutConfig spoutConf)
Method Detail

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 © 2015 The Apache Software Foundation. All Rights Reserved.