pgsql-kafka proxy

The pgsql-kafka proxy binding for adapting pgsql request-response streams to kafka topic streams.

pgsql_kafka_proxy:
  type: pgsql-kafka
  kind: proxy
  catalog:
    catalog0:
      - strategy: topic
  exit: kafka_client

Configuration (* required)

catalog

object as map of named array

To map defined catalog for schema retrieval based on catalog specific parameters. Any of the possible combination can be configured.

id

catalog:
  my_catalog:
    - id: unique-catalog-id

---

strategy

catalog:
  my_catalog:
    - strategy: topic

---

subject

catalog:
  my_catalog:
    - subject: http

catalog[].strategy*

enum [ topic ]

To determine the subject based on the specified strategy

catalog[].subject*

string

Unique identifier for schema categorization in the catalog.

catalog[].version

string | Default: latest

Specific iteration or version of a registered schema in the defined catalog.

catalog[].id*

integer

Define specific schema id to refer from catalog.

exit

string

exit: pgsql_tcp_client

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.