Uses of Class
org.flowable.eventregistry.model.KafkaInboundChannelModel

Packages that use KafkaInboundChannelModel

Package	Description
org.flowable.eventregistry.impl.model
org.flowable.eventregistry.spring.kafka
org.flowable.eventregistry.spring.kafka.payload

Uses of KafkaInboundChannelModel in org.flowable.eventregistry.impl.model

Fields in org.flowable.eventregistry.impl.model declared as KafkaInboundChannelModel

Modifier and Type	Field	Description
protected KafkaInboundChannelModel	InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl.kafkaChannel

Constructors in org.flowable.eventregistry.impl.model with parameters of type KafkaInboundChannelModel

Modifier	Constructor	Description
	InboundKafkaChannelBuilderImpl(KafkaInboundChannelModel kafkaChannel, EventRepositoryService eventRepositoryService, InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)

Uses of KafkaInboundChannelModel in org.flowable.eventregistry.spring.kafka

Methods in org.flowable.eventregistry.spring.kafka with parameters of type KafkaInboundChannelModel

Modifier and Type	Method	Description
protected Collection<KafkaChannelDefinitionProcessor.Configuration>	KafkaChannelDefinitionProcessor.createEndpointConfigurations(KafkaInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry, KafkaListenerEndpoint mainEndpoint, KafkaListenerContainerFactory<?> containerFactory)
protected KafkaListenerEndpoint	KafkaChannelDefinitionProcessor.createKafkaListenerEndpoint(KafkaInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
protected String	KafkaChannelDefinitionProcessor.getEndpointGroupId(KafkaInboundChannelModel channelDefinition, String id)
protected void	KafkaChannelDefinitionProcessor.processAndRegisterEndpoints(KafkaInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
protected Pattern	KafkaChannelDefinitionProcessor.resolvePattern(KafkaInboundChannelModel channelModel)
protected KafkaChannelDefinitionProcessor.ResolvedRetryConfiguration	KafkaChannelDefinitionProcessor.resolveRetryConfiguration(KafkaInboundChannelModel channelModel)
protected Collection<TopicPartitionOffset>	KafkaChannelDefinitionProcessor.resolveTopicPartitions(KafkaInboundChannelModel channelModel)
protected void	KafkaChannelDefinitionProcessor.resolveTopics(Object resolvedValue, List<String> result, KafkaInboundChannelModel channelDefinition)
protected Collection<String>	KafkaChannelDefinitionProcessor.resolveTopics(KafkaInboundChannelModel channelDefinition)

Uses of KafkaInboundChannelModel in org.flowable.eventregistry.spring.kafka.payload

Methods in org.flowable.eventregistry.spring.kafka.payload with parameters of type KafkaInboundChannelModel

Modifier and Type	Method	Description
protected Collection<EventPayloadInstance>	KafkaConsumerRecordInformationPayloadExtractor.extractPayload(EventModel eventModel, KafkaInboundChannelModel inboundChannel, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)