Kafka

Dieser Inhalt ist noch nicht in deiner Sprache verfügbar.

{
  "name": "orders",
  "brokers": ["kafka-1:9093", "kafka-2:9093"],
  "clientId": "openagentix",
  "groupId": "openagentix-orders",
  "topics": ["orders.failed"],
  "fromBeginning": false,
  "ssl": { "caSecret": "kafka.ca", "rejectUnauthorized": true },
  "sasl": { "mechanism": "scram-sha-512", "username": "oax", "passwordSecret": "kafka.password" }
}

Field	Default
`clientId`	`openagentix`
`fromBeginning`	`false`
`ssl`	`false`; `true` or `{ caSecret, certSecret, keySecret, rejectUnauthorized }` with PEM material in secrets
`sasl.mechanism`	`plain`, `scram-sha-256` or `scram-sha-512`

Secrets are references, never values.

Messages

CloudEvents binary mode: headers ce_specversion: 1.0 and ce_type (plus ce_id, ce_source, ce_subject, ce_time, content-type).
Structured mode: a JSON body with specversion.
Anything else becomes io.openagentix.kafka.message with the ID <topic>-<partition>-<offset> and data: { topic, partition, key, value }.

If handling a message fails, the consumer retries it.

Trigger an agent with:

triggers:
  - type: kafka
    topic: orders.failed