public class KafkaConsumerNode extends Node
KafkaConsumerNode instance
Change Activity: -------- ----------- ------------- ------------------------------------ Reason: Date: Originator: Comments: -------- ----------- ------------- ------------------------------------ xxxxx.x 2010-08-10 dstorey creation xxxxx.x xxxx-xx-xx generated 7.0.0.2 Release
Modifier and Type | Class and Description |
---|---|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_COMPONENTLEVEL
ENUM_KAFKACONSUMER_COMPONENTLEVEL
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_INITIALOFFSET
ENUM_KAFKACONSUMER_INITIALOFFSET
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE
ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE
ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE
ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_SECURITYPROTOCOL
ENUM_KAFKACONSUMER_SECURITYPROTOCOL
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION
ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEMASTER
ENUM_KAFKACONSUMER_VALIDATEMASTER
|
static class |
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATETIMING
ENUM_KAFKACONSUMER_VALIDATETIMING
|
class |
KafkaConsumerNode.OpaqueElementsRow
OpaqueElementsRow is used by ParserXmlnscOpaqueElementsTable instance
|
class |
KafkaConsumerNode.ParserXmlnscOpaqueElementsTable
ParserXmlnscOpaqueElementsTable instance contains OpaqueElementsRow rows
|
Node.RotationKind
Modifier and Type | Field and Description |
---|---|
OutputTerminal |
OUTPUT_TERMINAL_CATCH |
OutputTerminal |
OUTPUT_TERMINAL_FAILURE |
OutputTerminal |
OUTPUT_TERMINAL_OUT |
Constructor and Description |
---|
KafkaConsumerNode() |
Modifier and Type | Method and Description |
---|---|
int |
getAdditionalInstances()
Get the KafkaConsumerNode Additional instances property
|
java.lang.String |
getBootstrapServers()
Get the KafkaConsumerNode "Bootstrap servers" property
|
java.lang.String |
getClientId()
Get the KafkaConsumerNode "Client ID" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_COMPONENTLEVEL |
getComponentLevel()
Get the KafkaConsumerNode "Additional instances pool" property
|
int |
getConnectionTimeout()
Get the KafkaConsumerNode Connection timeout (sec) property
|
java.lang.String |
getConnectorName()
Get the KafkaConsumerNode "ConnectorName" property
|
boolean |
getEnableAutoCommit()
Get the KafkaConsumerNode "Commit message offset in Kafka" property
|
java.lang.String |
getGroupId()
Get the KafkaConsumerNode "Consumer group ID" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_INITIALOFFSET |
getInitialOffset()
Get the KafkaConsumerNode "Default message offset" property
|
InputTerminal[] |
getInputTerminals()
Gets the full list of available InputTerminals for this Node
|
java.lang.String |
getMessageDomainProperty()
Get the KafkaConsumerNode "Message domain" property
|
java.lang.String |
getMessageFormatProperty()
Get the KafkaConsumerNode "Physical format" property
|
java.lang.String |
getMessageSetProperty()
Get the KafkaConsumerNode "Message model" property
|
java.lang.String |
getMessageTypeProperty()
Get the KafkaConsumerNode "Message" property
|
java.lang.String |
getNodeName()
Gets the label name of this node
|
OutputTerminal[] |
getOutputTerminals()
Gets the full list of available OutputTerminals for this Node
|
boolean |
getParserXmlnscBuildTreeUsingXMLSchema()
Get the KafkaConsumerNode "Build tree using XML schema data types" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE |
getParserXmlnscCommentsRetainMode()
Get the KafkaConsumerNode "Retain comments" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE |
getParserXmlnscMixedContentRetainMode()
Get the KafkaConsumerNode "Retain mixed content" property
|
KafkaConsumerNode.ParserXmlnscOpaqueElementsTable |
getParserXmlnscOpaqueElementsTable()
Retrieve the Opaque elements table for the node KafkaConsumerNode
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE |
getParserXmlnscProcessingInstructionsRetainMode()
Get the KafkaConsumerNode "Retain processing instructions" property
|
boolean |
getParserXmlnscUseForXmlnsDomain()
Get the KafkaConsumerNode "Use XMLNSC compact parser for XMLNS domain" property
|
int |
getReceiveBatchSize()
Get the KafkaConsumerNode Receive batch size property
|
java.lang.String |
getSecurityIdentity()
Get the KafkaConsumerNode "Security identity" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_SECURITYPROTOCOL |
getSecurityProtocol()
Get the KafkaConsumerNode "Security protocol" property
|
int |
getSessionTimeout()
Get the KafkaConsumerNode Session timeout (sec) property
|
java.lang.String |
getSslProtocol()
Get the KafkaConsumerNode "SSL protocol" property
|
java.lang.String |
getTopicName()
Get the KafkaConsumerNode "Topic name" property
|
java.lang.String |
getTypeName()
Gets the node type of this node
|
boolean |
getUseClientIdSuffix()
Get the KafkaConsumerNode "Add App Connect Enterprise suffix to client ID" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION |
getValidateFailureAction()
Get the KafkaConsumerNode "Failure action" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEMASTER |
getValidateMaster()
Get the KafkaConsumerNode "Validate" property
|
KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATETIMING |
getValidateTiming()
Get the KafkaConsumerNode "Parse timing" property
|
KafkaConsumerNode |
setAdditionalInstances(int value)
Set the KafkaConsumerNode "Additional instances" property
|
KafkaConsumerNode |
setBootstrapServers(java.lang.String value)
Set the KafkaConsumerNode "Bootstrap servers" property
|
KafkaConsumerNode |
setClientId(java.lang.String value)
Set the KafkaConsumerNode "Client ID" property
|
KafkaConsumerNode |
setComponentLevel(KafkaConsumerNode.ENUM_KAFKACONSUMER_COMPONENTLEVEL value)
Set the KafkaConsumerNode "Additional instances pool" property
|
KafkaConsumerNode |
setConnectionTimeout(int value)
Set the KafkaConsumerNode "Connection timeout (sec)" property
|
KafkaConsumerNode |
setConnectorName(java.lang.String value)
Set the KafkaConsumerNode "ConnectorName" property
|
KafkaConsumerNode |
setEnableAutoCommit(boolean value)
Set the KafkaConsumerNode "Commit message offset in Kafka" property
|
KafkaConsumerNode |
setGroupId(java.lang.String value)
Set the KafkaConsumerNode "Consumer group ID" property
|
KafkaConsumerNode |
setInitialOffset(KafkaConsumerNode.ENUM_KAFKACONSUMER_INITIALOFFSET value)
Set the KafkaConsumerNode "Default message offset" property
|
KafkaConsumerNode |
setMessageDomainProperty(java.lang.String value)
Set the KafkaConsumerNode "Message domain" property
|
KafkaConsumerNode |
setMessageFormatProperty(java.lang.String value)
Set the KafkaConsumerNode "Physical format" property
|
KafkaConsumerNode |
setMessageSetProperty(java.lang.String value)
Set the KafkaConsumerNode "Message model" property
|
KafkaConsumerNode |
setMessageTypeProperty(java.lang.String value)
Set the KafkaConsumerNode "Message" property
|
KafkaConsumerNode |
setParserXmlnscBuildTreeUsingXMLSchema(boolean value)
Set the KafkaConsumerNode "Build tree using XML schema data types" property
|
KafkaConsumerNode |
setParserXmlnscCommentsRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE value)
Set the KafkaConsumerNode "Retain comments" property
|
KafkaConsumerNode |
setParserXmlnscMixedContentRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE value)
Set the KafkaConsumerNode "Retain mixed content" property
|
KafkaConsumerNode |
setParserXmlnscProcessingInstructionsRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE value)
Set the KafkaConsumerNode "Retain processing instructions" property
|
KafkaConsumerNode |
setParserXmlnscUseForXmlnsDomain(boolean value)
Set the KafkaConsumerNode "Use XMLNSC compact parser for XMLNS domain" property
|
KafkaConsumerNode |
setReceiveBatchSize(int value)
Set the KafkaConsumerNode "Receive batch size" property
|
KafkaConsumerNode |
setSecurityIdentity(java.lang.String value)
Set the KafkaConsumerNode "Security identity" property
|
KafkaConsumerNode |
setSecurityProtocol(KafkaConsumerNode.ENUM_KAFKACONSUMER_SECURITYPROTOCOL value)
Set the KafkaConsumerNode "Security protocol" property
|
KafkaConsumerNode |
setSessionTimeout(int value)
Set the KafkaConsumerNode "Session timeout (sec)" property
|
KafkaConsumerNode |
setSslProtocol(java.lang.String value)
Set the KafkaConsumerNode "SSL protocol" property
|
KafkaConsumerNode |
setTopicName(java.lang.String value)
Set the KafkaConsumerNode "Topic name" property
|
KafkaConsumerNode |
setUseClientIdSuffix(boolean value)
Set the KafkaConsumerNode "Add App Connect Enterprise suffix to client ID" property
|
KafkaConsumerNode |
setValidateFailureAction(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION value)
Set the KafkaConsumerNode "Failure action" property
|
KafkaConsumerNode |
setValidateMaster(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEMASTER value)
Set the KafkaConsumerNode "Validate" property
|
KafkaConsumerNode |
setValidateTiming(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATETIMING value)
Set the KafkaConsumerNode "Parse timing" property
|
addNsmapping, clone, findPropertyByName, getInputTerminal, getInputTerminal, getInstanceNodeProperties, getLocation, getLongDescription, getMandatoryPropertyNames, getNodePropertyTables, getNsmappingtables, getOutputTerminal, getOutputTerminal, getPropertyDefaultValue, getPropertyNames, getPropertyValue, getRotate, getShortDescription, isUdpSupport, removeNsmapping, setLocation, setLocation, setLongDescription, setNodeName, setNsmappingtables, setProperty, setRotate, setShortDescription, toString
public final OutputTerminal OUTPUT_TERMINAL_CATCH
public final OutputTerminal OUTPUT_TERMINAL_FAILURE
public final OutputTerminal OUTPUT_TERMINAL_OUT
public KafkaConsumerNode.ParserXmlnscOpaqueElementsTable getParserXmlnscOpaqueElementsTable()
public InputTerminal[] getInputTerminals()
Node
getInputTerminals
in class Node
public OutputTerminal[] getOutputTerminals()
Node
getOutputTerminals
in class Node
public java.lang.String getTypeName()
Node
getTypeName
in class Node
public KafkaConsumerNode setConnectorName(java.lang.String value)
value
- String ; the value to set the property "ConnectorName"public java.lang.String getConnectorName()
public KafkaConsumerNode setTopicName(java.lang.String value)
value
- String ; the value to set the property "Topic name"public java.lang.String getTopicName()
public KafkaConsumerNode setBootstrapServers(java.lang.String value)
value
- String ; the value to set the property "Bootstrap servers"public java.lang.String getBootstrapServers()
public KafkaConsumerNode setGroupId(java.lang.String value)
value
- String ; the value to set the property "Consumer group ID"public java.lang.String getGroupId()
public KafkaConsumerNode setInitialOffset(KafkaConsumerNode.ENUM_KAFKACONSUMER_INITIALOFFSET value)
value
- ENUM_KAFKACONSUMER_INITIALOFFSET ; the value to set the property "Default message offset"public KafkaConsumerNode.ENUM_KAFKACONSUMER_INITIALOFFSET getInitialOffset()
public KafkaConsumerNode setEnableAutoCommit(boolean value)
value
- boolean ; the value to set the property "Commit message offset in Kafka"public boolean getEnableAutoCommit()
public KafkaConsumerNode setClientId(java.lang.String value)
value
- String ; the value to set the property "Client ID"public java.lang.String getClientId()
public KafkaConsumerNode setUseClientIdSuffix(boolean value)
value
- boolean ; the value to set the property "Add App Connect Enterprise suffix to client ID"public boolean getUseClientIdSuffix()
public KafkaConsumerNode setConnectionTimeout(int value)
value
- int ; the value to set the property "Connection timeout (sec)"public int getConnectionTimeout()
public KafkaConsumerNode setSessionTimeout(int value)
value
- int ; the value to set the property "Session timeout (sec)"public int getSessionTimeout()
public KafkaConsumerNode setReceiveBatchSize(int value)
value
- int ; the value to set the property "Receive batch size"public int getReceiveBatchSize()
public KafkaConsumerNode setSecurityProtocol(KafkaConsumerNode.ENUM_KAFKACONSUMER_SECURITYPROTOCOL value)
value
- ENUM_KAFKACONSUMER_SECURITYPROTOCOL ; the value to set the property "Security protocol"public KafkaConsumerNode.ENUM_KAFKACONSUMER_SECURITYPROTOCOL getSecurityProtocol()
public KafkaConsumerNode setSslProtocol(java.lang.String value)
value
- String ; the value to set the property "SSL protocol"public java.lang.String getSslProtocol()
public KafkaConsumerNode setSecurityIdentity(java.lang.String value)
value
- String ; the value to set the property "Security identity"public java.lang.String getSecurityIdentity()
public KafkaConsumerNode setMessageDomainProperty(java.lang.String value)
value
- String ; the value to set the property "Message domain"public java.lang.String getMessageDomainProperty()
public KafkaConsumerNode setMessageSetProperty(java.lang.String value)
value
- String ; the value to set the property "Message model"public java.lang.String getMessageSetProperty()
public KafkaConsumerNode setMessageTypeProperty(java.lang.String value)
value
- String ; the value to set the property "Message"public java.lang.String getMessageTypeProperty()
public KafkaConsumerNode setMessageFormatProperty(java.lang.String value)
value
- String ; the value to set the property "Physical format"public java.lang.String getMessageFormatProperty()
public KafkaConsumerNode setValidateTiming(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATETIMING value)
value
- ENUM_KAFKACONSUMER_VALIDATETIMING ; the value to set the property "Parse timing"public KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATETIMING getValidateTiming()
public KafkaConsumerNode setParserXmlnscBuildTreeUsingXMLSchema(boolean value)
value
- boolean ; the value to set the property "Build tree using XML schema data types"public boolean getParserXmlnscBuildTreeUsingXMLSchema()
public KafkaConsumerNode setParserXmlnscUseForXmlnsDomain(boolean value)
value
- boolean ; the value to set the property "Use XMLNSC compact parser for XMLNS domain"public boolean getParserXmlnscUseForXmlnsDomain()
public KafkaConsumerNode setParserXmlnscMixedContentRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE value)
value
- ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE ; the value to set the property "Retain mixed content"public KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCMIXEDCONTENTRETAINMODE getParserXmlnscMixedContentRetainMode()
public KafkaConsumerNode setParserXmlnscCommentsRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE value)
value
- ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE ; the value to set the property "Retain comments"public KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCCOMMENTSRETAINMODE getParserXmlnscCommentsRetainMode()
public KafkaConsumerNode setParserXmlnscProcessingInstructionsRetainMode(KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE value)
value
- ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE ; the value to set the property "Retain processing instructions"public KafkaConsumerNode.ENUM_KAFKACONSUMER_PARSERXMLNSCPROCESSINGINSTRUCTIONSRETAINMODE getParserXmlnscProcessingInstructionsRetainMode()
public KafkaConsumerNode setValidateMaster(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEMASTER value)
value
- ENUM_KAFKACONSUMER_VALIDATEMASTER ; the value to set the property "Validate"public KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEMASTER getValidateMaster()
public KafkaConsumerNode setValidateFailureAction(KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION value)
value
- ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION ; the value to set the property "Failure action"public KafkaConsumerNode.ENUM_KAFKACONSUMER_VALIDATEFAILUREACTION getValidateFailureAction()
public KafkaConsumerNode setComponentLevel(KafkaConsumerNode.ENUM_KAFKACONSUMER_COMPONENTLEVEL value)
value
- ENUM_KAFKACONSUMER_COMPONENTLEVEL ; the value to set the property "Additional instances pool"public KafkaConsumerNode.ENUM_KAFKACONSUMER_COMPONENTLEVEL getComponentLevel()
public KafkaConsumerNode setAdditionalInstances(int value)
value
- int ; the value to set the property "Additional instances"public int getAdditionalInstances()
public java.lang.String getNodeName()
Node
MessageFlow mf1 = patternInstanceManager.getMessageFlow("MyFlowProject", "mf1.msgflow"); Node inputMQNode = mf1.getNodeByName("My Input Node"); inputMQNode.setNodeName("Renamed Input Node");
getNodeName
in class Node