Package org.flowable.eventregistry.api.model

Interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

Enclosing interface:

InboundChannelModelBuilder

public static interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

Builder to create an InboundEventChannelAdapter using Kafka.

Method Summary

Modifier and Type	Method	Description
InboundChannelModelBuilder.InboundKafkaChannelBuilder	clientIdPrefix(String clientIdPrefix)	Sets the client id prefix for this Kafka adapter.
InboundChannelModelBuilder.InboundKafkaChannelBuilder	concurrency(String concurrency)	Sets the concurrency (and integer) for this Kafka adapter.
InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder	eventProcessingPipeline()	Continue building the InboundChannelModel by configuring the next parts (if any).
InboundChannelModelBuilder.InboundKafkaChannelBuilder	groupId(String groupId)	Sets the groupId for this Kafka adapter.
InboundChannelModelBuilder.InboundKafkaChannelBuilder	property(String name, String value)	Sets custom properties for this Kafka adapter.

Method Detail

groupId

InboundChannelModelBuilder.InboundKafkaChannelBuilder groupId(String groupId)

Sets the groupId for this Kafka adapter. See Kafka docs for more info.

clientIdPrefix

InboundChannelModelBuilder.InboundKafkaChannelBuilder clientIdPrefix(String clientIdPrefix)

Sets the client id prefix for this Kafka adapter. See Kafka docs for more info.

concurrency

InboundChannelModelBuilder.InboundKafkaChannelBuilder concurrency(String concurrency)

Sets the concurrency (and integer) for this Kafka adapter. See the Spring Kafka docs for more information.

property

InboundChannelModelBuilder.InboundKafkaChannelBuilder property(String name,
                                                               String value)

Sets custom properties for this Kafka adapter. See the Spring Kafka docs for more information.

eventProcessingPipeline

InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder eventProcessingPipeline()

Continue building the InboundChannelModel by configuring the next parts (if any).