kafka cache_client

The kafka cache_client binding supports filtering by kafka message key, headers or a combination of key and headers.

kafka_cache_client:
  type: kafka
  kind: cache_client
  exit: kafka_cache_server

Configuration (* required)

options

object

The cache_client specific options.

options:
  topics:
    - name: items-requests

options.topics

array of object

Topic configuration.

topics[].name

string

Topic name.

topics[].key

enum [ avro, boolean, bytes, double, float, int32, int64, json, protobuf, string, vector ] as string, or object

Enforce validation for key

key.model*

enum [ avro, boolean, bytes, double, float, int32, int64, json, protobuf, string, vector ]

A schema or type to validate the topic's key. Refer to the individual model docs for type specific implementation.

key.validate

enum [ strict, lenient ] as string, or object | Default: strict

Controls how strictly the key model enforces conformance to the schema. Can also be set independently for decode and encode.

topics[].value

enum [ avro, boolean, bytes, double, float, int32, int64, json, protobuf, string, vector ] as string, or object

Enforce validation for value

value.model*

enum [ avro, boolean, bytes, double, float, int32, int64, json, protobuf, string, vector ]

A schema or type to validate the topic's value. Refer to the individual model docs for type specific implementation.

value.validate

enum [ strict, lenient ] as string, or object | Default: strict

Controls how strictly the value model enforces conformance to the schema. Can also be set independently for decode and encode.

validate.decode

enum [ strict, lenient ]

Validation mode applied when decoding the key or value.

validate.encode

enum [ strict, lenient ]

Validation mode applied when encoding the key or value.

routes

array of object

Conditional kafka specific routes. At least one of routes or the top-level exit is required.

routes[].guarded

object as map of named array of string

List of roles required by each named guard to authorize this route.

routes:
  - guarded:
      my_guard:
        - read:items

routes[].when

array of object

List of conditions (any match) to match this route. Read more: When a route matches

when[].topic

string

Topic name pattern.

routes[].exit

string

Next binding when following this route.

exit: echo_server

exit

string

Default exit binding when no conditional routes are viable.

exit: echo_server

telemetry

object

Defines the desired telemetry for the binding.

telemetry.metrics

array

Telemetry metrics to track

telemetry:
  metrics:
    - stream.*

telemetry.attributes

object as map of named string properties

Telemetry attributes to add to the binding metrics.