public class KafkaBoltFactory extends Object implements org.thales.punch.libraries.storm.api.IBoltFactory
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated bolt.
|
Constructor and Description |
---|
KafkaBoltFactory()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
org.apache.storm.topology.IRichBolt |
createBolt(org.thales.punch.platform.api.IPlatform platform,
org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig) |
protected Properties |
createComponentSettings(org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
Creates settings needed by the Kafka producer.
|
List<org.thales.punch.libraries.storm.api.StreamDeclaration> |
getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings) |
public static final String TYPE
public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)
getPublishedStreamConfig
in interface org.thales.punch.libraries.storm.api.IBoltFactory
public org.apache.storm.topology.IRichBolt createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings boltConfig, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig) throws org.thales.punch.exceptions.ConfigurationException
createBolt
in interface org.thales.punch.libraries.storm.api.IBoltFactory
org.thales.punch.exceptions.ConfigurationException
protected Properties createComponentSettings(org.thales.punch.libraries.storm.api.NodeSettings boltConfig, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig) throws org.thales.punch.exceptions.ConfigurationException
boltConfig
- the bolt configuration.topoConfig
- topoconfigpunchplatformConfig
- punchplatformConfigorg.thales.punch.exceptions.ConfigurationException
Copyright © 2023. All rights reserved.