Knative

Send and receive events from Knative.

What’s inside

Knative component, URI syntax: knative:type/typeId

Please refer to the above links for usage and configuration details.

Maven coordinates

<dependency>
    <groupId>org.apache.camel.springboot</groupId>
    <artifactId>camel-knative-starter</artifactId>
</dependency>

Spring Boot Auto-Configuration

The starter supports 23 options, which are listed below.

Name	Description	Default	Type
camel.component.knative.api-version	The version of the k8s resource referenced by the endpoint.		String
camel.component.knative.autowired-enabled	Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.	true	Boolean
camel.component.knative.bridge-error-handler	Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. Important: This is only possible if the 3rd party component allows Camel to be alerted if an exception was thrown. Some components handle this internally only, and therefore bridgeErrorHandler is not possible. In other situations we may improve the Camel component to hook into the 3rd party component and make this possible for future releases. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.	false	Boolean
camel.component.knative.ce-override	CloudEvent headers to override		String>
camel.component.knative.cloud-events-spec-version	Set the version of the cloudevents spec.	1.0	String
camel.component.knative.cloud-events-type	Set the event-type information of the produced events.	org.apache.camel.event	String
camel.component.knative.configuration	Set the configuration. The option is a org.apache.camel.component.knative.KnativeConfiguration type.		KnativeConfiguration
camel.component.knative.consumer-factory	The protocol consumer factory. The option is a org.apache.camel.component.knative.spi.KnativeConsumerFactory type.		KnativeConsumerFactory
camel.component.knative.enabled	Whether to enable auto configuration of the knative component. This is enabled by default.		Boolean
camel.component.knative.environment	The environment. The option is a org.apache.camel.component.knative.spi.KnativeEnvironment type.		KnativeEnvironment
camel.component.knative.environment-path	The path ot the environment definition		String
camel.component.knative.filters	Set the filters.		String>
camel.component.knative.health-check-consumer-enabled	Used for enabling or disabling all consumer based health checks from this component	true	Boolean
camel.component.knative.health-check-producer-enabled	Used for enabling or disabling all producer based health checks from this component. Notice: Camel has by default disabled all producer based health-checks. You can turn on producer checks globally by setting camel.health.producersEnabled=true.	true	Boolean
camel.component.knative.kind	The type of the k8s resource referenced by the endpoint.		String
camel.component.knative.lazy-start-producer	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.	false	Boolean
camel.component.knative.name	The name of the k8s resource referenced by the endpoint.		String
camel.component.knative.producer-factory	The protocol producer factory. The option is a org.apache.camel.component.knative.spi.KnativeProducerFactory type.		KnativeProducerFactory
camel.component.knative.reply	If the consumer should construct a full reply to knative request.	true	Boolean
camel.component.knative.reply-with-cloud-event	Transforms the reply into a cloud event that will be processed by the caller. When listening to events from a Knative Broker, if this flag is enabled, replies will be published to the same Broker where the request comes from (beware that if you don’t change the type of the received message, you may create a loop and receive your same reply). When this flag is disabled, CloudEvent headers are removed from the reply.	false	Boolean
camel.component.knative.sink-binding	The SinkBinding configuration. The option is a org.apache.camel.component.knative.spi.KnativeSinkBinding type.		KnativeSinkBinding
camel.component.knative.transport-options	Set the transport options.		Object>
camel.component.knative.type-id	The name of the service to lookup from the KnativeEnvironment.		String

Name

Description

Default

Type

camel.component.knative.api-version

The version of the k8s resource referenced by the endpoint.

String

camel.component.knative.autowired-enabled

Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.

true

Boolean

camel.component.knative.bridge-error-handler

Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. Important: This is only possible if the 3rd party component allows Camel to be alerted if an exception was thrown. Some components handle this internally only, and therefore bridgeErrorHandler is not possible. In other situations we may improve the Camel component to hook into the 3rd party component and make this possible for future releases. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.

false

Boolean

camel.component.knative.ce-override

CloudEvent headers to override

String>

camel.component.knative.cloud-events-spec-version

Set the version of the cloudevents spec.

1.0

String

camel.component.knative.cloud-events-type

Set the event-type information of the produced events.

org.apache.camel.event

String

camel.component.knative.configuration

Set the configuration. The option is a org.apache.camel.component.knative.KnativeConfiguration type.

KnativeConfiguration

camel.component.knative.consumer-factory

The protocol consumer factory. The option is a org.apache.camel.component.knative.spi.KnativeConsumerFactory type.

KnativeConsumerFactory

camel.component.knative.enabled

Whether to enable auto configuration of the knative component. This is enabled by default.

Boolean

camel.component.knative.environment

The environment. The option is a org.apache.camel.component.knative.spi.KnativeEnvironment type.

KnativeEnvironment

camel.component.knative.environment-path

The path ot the environment definition

String

camel.component.knative.filters

Set the filters.

String>

camel.component.knative.health-check-consumer-enabled

Used for enabling or disabling all consumer based health checks from this component

true

Boolean

camel.component.knative.health-check-producer-enabled

Used for enabling or disabling all producer based health checks from this component. Notice: Camel has by default disabled all producer based health-checks. You can turn on producer checks globally by setting camel.health.producersEnabled=true.

true

Boolean

camel.component.knative.kind

The type of the k8s resource referenced by the endpoint.

String

camel.component.knative.lazy-start-producer

Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.

false

Boolean

camel.component.knative.name

The name of the k8s resource referenced by the endpoint.

String

camel.component.knative.producer-factory

The protocol producer factory. The option is a org.apache.camel.component.knative.spi.KnativeProducerFactory type.

KnativeProducerFactory

camel.component.knative.reply

If the consumer should construct a full reply to knative request.

true

Boolean

camel.component.knative.reply-with-cloud-event

Transforms the reply into a cloud event that will be processed by the caller. When listening to events from a Knative Broker, if this flag is enabled, replies will be published to the same Broker where the request comes from (beware that if you don’t change the type of the received message, you may create a loop and receive your same reply). When this flag is disabled, CloudEvent headers are removed from the reply.

false

Boolean

camel.component.knative.sink-binding

The SinkBinding configuration. The option is a org.apache.camel.component.knative.spi.KnativeSinkBinding type.

KnativeSinkBinding

camel.component.knative.transport-options

Set the transport options.

Object>

camel.component.knative.type-id

The name of the service to lookup from the KnativeEnvironment.

String