org.flowable.eventregistry.model

Class KafkaInboundChannelModel

java.lang.Object

org.flowable.eventregistry.model.ChannelModel

org.flowable.eventregistry.model.InboundChannelModel

org.flowable.eventregistry.model.KafkaInboundChannelModel

public class KafkaInboundChannelModel
extends InboundChannelModel

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaInboundChannelModel.CustomProperty
static class	KafkaInboundChannelModel.NonBlockingRetryBackOff
static class	KafkaInboundChannelModel.RetryConfiguration
static class	KafkaInboundChannelModel.TopicPartition

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clientIdPrefix
protected String	concurrency
protected List<KafkaInboundChannelModel.CustomProperty>	customProperties
protected String	groupId
protected String	offsetOutputName
protected String	partitionOutputName
protected KafkaInboundChannelModel.RetryConfiguration	retry
protected String	topicOutputName
protected Collection<KafkaInboundChannelModel.TopicPartition>	topicPartitions
protected String	topicPattern
protected Collection<String>	topics

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

channelEventKeyDetection, channelEventTenantIdDetection, contextExtractorDelegateExpression, deserializerDelegateExpression, deserializerType, eventTransformerDelegateExpression, headerExtractorDelegateExpression, inboundEventChannelAdapter, inboundEventProcessingPipeline, payloadExtractorDelegateExpression, pipelineDelegateExpression

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

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

Constructor Summary

Constructors

Constructor and Description
KafkaInboundChannelModel()

Method Summary

Modifier and Type	Method and Description
void	addCustomProperty(String name, String value)
String	getClientIdPrefix()
String	getConcurrency()
List<KafkaInboundChannelModel.CustomProperty>	getCustomProperties()
String	getGroupId()
String	getOffsetOutputName()
String	getPartitionOutputName()
KafkaInboundChannelModel.RetryConfiguration	getRetry()
String	getTopicOutputName()
Collection<KafkaInboundChannelModel.TopicPartition>	getTopicPartitions()
String	getTopicPattern()
Collection<String>	getTopics()
void	setClientIdPrefix(String clientIdPrefix)
void	setConcurrency(String concurrency)
void	setCustomProperties(List<KafkaInboundChannelModel.CustomProperty> properties)
void	setGroupId(String groupId)
void	setOffsetOutputName(String offsetOutputName)
void	setPartitionOutputName(String partitionOutputName)
void	setRetry(KafkaInboundChannelModel.RetryConfiguration retry)
void	setTopicOutputName(String topicOutputName)
void	setTopicPartitions(Collection<KafkaInboundChannelModel.TopicPartition> topicPartitions)
void	setTopicPattern(String topicPattern)
void	setTopics(Collection<String> topics)

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

getChannelEventKeyDetection, getChannelEventTenantIdDetection, getContextExtractorDelegateExpression, getDeserializerDelegateExpression, getDeserializerType, getEventTransformerDelegateExpression, getHeaderExtractorDelegateExpression, getInboundEventChannelAdapter, getInboundEventProcessingPipeline, getPayloadExtractorDelegateExpression, getPipelineDelegateExpression, setChannelEventKeyDetection, setChannelEventTenantIdDetection, setContextExtractorDelegateExpression, setDeserializerDelegateExpression, setDeserializerType, setEventTransformerDelegateExpression, setHeaderExtractorDelegateExpression, setInboundEventChannelAdapter, setInboundEventProcessingPipeline, setPayloadExtractorDelegateExpression, setPipelineDelegateExpression

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

groupId

protected String groupId

topics

protected Collection<String> topics

topicPattern

protected String topicPattern

topicPartitions

protected Collection<KafkaInboundChannelModel.TopicPartition> topicPartitions

clientIdPrefix

protected String clientIdPrefix

concurrency

protected String concurrency

retry

protected KafkaInboundChannelModel.RetryConfiguration retry

customProperties

protected List<KafkaInboundChannelModel.CustomProperty> customProperties

partitionOutputName

protected String partitionOutputName

offsetOutputName

protected String offsetOutputName

topicOutputName

protected String topicOutputName

Constructor Detail

KafkaInboundChannelModel

public KafkaInboundChannelModel()

Method Detail

getGroupId

public String getGroupId()

setGroupId

public void setGroupId(String groupId)

getTopics

public Collection<String> getTopics()

setTopics

public void setTopics(Collection<String> topics)

getTopicPattern

public String getTopicPattern()

setTopicPattern

public void setTopicPattern(String topicPattern)

getTopicPartitions

public Collection<KafkaInboundChannelModel.TopicPartition> getTopicPartitions()

setTopicPartitions

public void setTopicPartitions(Collection<KafkaInboundChannelModel.TopicPartition> topicPartitions)

getClientIdPrefix

public String getClientIdPrefix()

setClientIdPrefix

public void setClientIdPrefix(String clientIdPrefix)

getConcurrency

public String getConcurrency()

setConcurrency

public void setConcurrency(String concurrency)

getRetry

public KafkaInboundChannelModel.RetryConfiguration getRetry()

setRetry

public void setRetry(KafkaInboundChannelModel.RetryConfiguration retry)

getCustomProperties

public List<KafkaInboundChannelModel.CustomProperty> getCustomProperties()

addCustomProperty

public void addCustomProperty(String name,
                              String value)

setCustomProperties

public void setCustomProperties(List<KafkaInboundChannelModel.CustomProperty> properties)

getPartitionOutputName

public String getPartitionOutputName()

setPartitionOutputName

public void setPartitionOutputName(String partitionOutputName)

getOffsetOutputName

public String getOffsetOutputName()

setOffsetOutputName

public void setOffsetOutputName(String offsetOutputName)

getTopicOutputName

public String getTopicOutputName()

setTopicOutputName

public void setTopicOutputName(String topicOutputName)