org.flowable.eventregistry.model

Class KafkaOutboundChannelModel

java.lang.Object

org.flowable.eventregistry.model.ChannelModel

org.flowable.eventregistry.model.OutboundChannelModel

org.flowable.eventregistry.model.KafkaOutboundChannelModel

public class KafkaOutboundChannelModel
extends OutboundChannelModel

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaOutboundChannelModel.KafkaPartition

Field Summary

Fields

Modifier and Type	Field and Description
protected KafkaOutboundChannelModel.KafkaPartition	partition
protected String	recordKey
protected String	topic

Fields inherited from class org.flowable.eventregistry.model.OutboundChannelModel

outboundEventChannelAdapter, outboundEventProcessingPipeline, pipelineDelegateExpression, serializerDelegateExpression, serializerType

Fields inherited from class org.flowable.eventregistry.model.ChannelModel

category, channelType, description, extension, key, name, type

Constructor Summary

Constructors

Constructor and Description
KafkaOutboundChannelModel()

Method Summary

Modifier and Type	Method and Description
KafkaOutboundChannelModel.KafkaPartition	getPartition()
String	getRecordKey()
String	getTopic()
void	setPartition(KafkaOutboundChannelModel.KafkaPartition partition)
void	setRecordKey(String recordKey)
void	setTopic(String topic)

Methods inherited from class org.flowable.eventregistry.model.OutboundChannelModel

getOutboundEventChannelAdapter, getOutboundEventProcessingPipeline, getPipelineDelegateExpression, getSerializerDelegateExpression, getSerializerType, setOutboundEventChannelAdapter, setOutboundEventProcessingPipeline, setPipelineDelegateExpression, setSerializerDelegateExpression, setSerializerType

Methods inherited from class org.flowable.eventregistry.model.ChannelModel

getCategory, getChannelType, getDescription, getExtension, getKey, getName, getType, setCategory, setChannelType, setDescription, setExtension, setKey, setName, setType

Methods inherited from class java.lang.Object

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

Field Detail

topic

protected String topic

recordKey

protected String recordKey

partition

protected KafkaOutboundChannelModel.KafkaPartition partition

Constructor Detail

KafkaOutboundChannelModel

public KafkaOutboundChannelModel()

Method Detail

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getRecordKey

public String getRecordKey()

setRecordKey

public void setRecordKey(String recordKey)

getPartition

public KafkaOutboundChannelModel.KafkaPartition getPartition()

setPartition

public void setPartition(KafkaOutboundChannelModel.KafkaPartition partition)