resume

Documentation

Index

• Constants
• func NewResumeTrait() trait.Trait
• type Trait

Constants

const (
	KafkaSingle  = "org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy"
	StrategyPath = "camel-k-offsets"
)

Functions

func NewResumeTrait

func NewResumeTrait() trait.Trait

Types

type Trait

type Trait struct {
	traitv1.Trait `property:",squash"`
	// Enables automatic configuration of the trait.
	Auto *bool `property:"auto" json:"auto,omitempty"`
	// The type of the resume strategy to use
	ResumeStrategy string `property:"resume-strategy,omitempty"`
	// The path used by the resume strategy (this is specific to the resume strategy type)
	ResumePath string `property:"resume-path,omitempty"`
	// The address of the resume server to use (protocol / implementation specific)
	ResumeServer string `property:"resume-server,omitempty"`
	// The adapter-specific policy to use when filling the cache (use: minimizing / maximizing). Check
	// the component documentation if unsure
	CacheFillPolicy string `property:"cache-fill-policy,omitempty"`
}

The Resume trait can be used to manage and configure resume strategies.

This feature is meant to allow quick resume of processing by Camel K instances after they have been restarted. This is an experimental implementation based on the support available on Camel Core resume strategies.

The Resume trait is disabled by default.

The main different from the implementation on Core is that it's not necessary to bind the strategies to the registry. This step will be done automatically by Camel K, after resolving the options passed to the trait.

A sample execution of this trait, using the Kafka backend (the only one supported at the moment), would require the following trait options: -t resume.enabled=true -t resume.resume-path=camel-file-sets -t resume.resume-server="address-of-your-kafka:9092"

+camel-k:trait=resume.