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, double, float, int32, int64, json, protobuf, string ] as string, or object

Enforce validation for key

key.model*

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

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

topics[].value

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

Enforce validation for value

value.model*

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

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

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.