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

Enforce validation for key

key.model*

enum [ avro, 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, double, float, int32, int64, json, protobuf, string ], object

Enforce validation for value

value.model*

enum [ avro, 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.

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.*