public class KafkaSpoutFactory extends Object implements org.thales.punch.libraries.storm.api.ISpoutFactory
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" : {
...
}
}
],
*
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated spout.
|
Constructor and Description |
---|
KafkaSpoutFactory()
Default constructor.
|
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) |
public static final String TYPE
public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings)
getPublishedStreamConfig
in interface org.thales.punch.libraries.storm.api.ISpoutFactory
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
createSpout
in interface org.thales.punch.libraries.storm.api.ISpoutFactory
org.thales.punch.exceptions.ConfigurationException
Copyright © 2023. All rights reserved.