Package 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	Description
static class	KafkaOutboundChannelModel.KafkaPartition
static class	KafkaOutboundChannelModel.RecordKey

Field Summary

Fields

Modifier and Type	Field	Description
protected KafkaOutboundChannelModel.KafkaPartition	partition
protected KafkaOutboundChannelModel.RecordKey	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	Description
KafkaOutboundChannelModel()

Method Summary

Modifier and Type	Method	Description
KafkaOutboundChannelModel.KafkaPartition	getPartition()
KafkaOutboundChannelModel.RecordKey	getRecordKey()
String	getTopic()
void	setPartition(KafkaOutboundChannelModel.KafkaPartition partition)
void	setRecordKey(KafkaOutboundChannelModel.RecordKey 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 Details

topic

protected String topic

recordKey

protected KafkaOutboundChannelModel.RecordKey recordKey

partition

protected KafkaOutboundChannelModel.KafkaPartition partition

Constructor Details

KafkaOutboundChannelModel

public KafkaOutboundChannelModel()

Method Details

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getRecordKey

public KafkaOutboundChannelModel.RecordKey getRecordKey()

setRecordKey

public void setRecordKey(KafkaOutboundChannelModel.RecordKey recordKey)

getPartition

public KafkaOutboundChannelModel.KafkaPartition getPartition()

setPartition

public void setPartition(KafkaOutboundChannelModel.KafkaPartition partition)