| Package | Description |
|---|---|
| org.flowable.eventregistry.impl.model | |
| org.flowable.eventregistry.spring.kafka |
| Modifier and Type | Field and Description |
|---|---|
protected KafkaInboundChannelModel |
InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl.kafkaChannel |
| Constructor and Description |
|---|
InboundKafkaChannelBuilderImpl(KafkaInboundChannelModel kafkaChannel,
EventRepositoryService eventRepositoryService,
InboundChannelDefinitionBuilderImpl channelDefinitionBuilder) |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.kafka.config.KafkaListenerEndpoint |
KafkaChannelDefinitionProcessor.createKafkaListenerEndpoint(KafkaInboundChannelModel channelModel,
String tenantId,
EventRegistry eventRegistry) |
protected String |
KafkaChannelDefinitionProcessor.getEndpointGroupId(KafkaInboundChannelModel channelDefinition,
String id) |
protected Pattern |
KafkaChannelDefinitionProcessor.resolvePattern(KafkaInboundChannelModel channelModel) |
protected Collection<String> |
KafkaChannelDefinitionProcessor.resolveTopics(KafkaInboundChannelModel channelDefinition) |
protected void |
KafkaChannelDefinitionProcessor.resolveTopics(Object resolvedValue,
List<String> result,
KafkaInboundChannelModel channelDefinition) |
Copyright © 2023 Flowable. All rights reserved.