org.thales.punch.libraries.storm.spout.factory

Class KafkaSpoutFactory

java.lang.Object

org.thales.punch.libraries.storm.spout.factory.KafkaSpoutFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.api.ISpoutFactory

public class KafkaSpoutFactory
extends Object
implements org.thales.punch.libraries.storm.api.ISpoutFactory

Build a KafkaInput from NodeSettings, ITopologySettings. and IPunchPlatformProperties.

The kafka spout expects a three-section settings maps:

        {
         "type" : "kafka_spout",
         "spout_settings" : {
             "start_offset_strategy" : "last_committed",
             "remote" : "casino",
             "brokers" : "kafka-casino",
             "load_control" : "rate",
             "load_control.rate" : 500,
             "load_control.adaptative" : true,
             "topic" : "lmc.apache",
             "fetch_size" : 204800
         },
         "storm_settings" : {
                        ...
                   }
   }
 ], 
 * 

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE The key referencing the associated spout.

Constructor Summary

Constructors

Constructor and Description
KafkaSpoutFactory() Default constructor.

Method Summary

Modifier and Type	Method and Description
org.thales.punch.libraries.storm.api.ISpout	createSpout(org.thales.punch.libraries.storm.api.NodeSettings settings, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
List<org.thales.punch.libraries.storm.api.StreamDeclaration>	getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings)

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final String TYPE

The key referencing the associated spout.

See Also:

Constant Field Values

Constructor Detail

KafkaSpoutFactory

public KafkaSpoutFactory()

Default constructor.

Method Detail

getPublishedStreamConfig

public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings)

Specified by:

getPublishedStreamConfig in interface org.thales.punch.libraries.storm.api.ISpoutFactory

createSpout

public org.thales.punch.libraries.storm.api.ISpout createSpout(org.thales.punch.libraries.storm.api.NodeSettings settings,
                                                               org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                                               org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
                                                        throws org.thales.punch.exceptions.ConfigurationException

Specified by:

createSpout in interface org.thales.punch.libraries.storm.api.ISpoutFactory

Throws:

org.thales.punch.exceptions.ConfigurationException