PluginsApache KafkaTriggersRealtimeTrigger

RealtimeTrigger

yaml

type: "io.kestra.plugin.kafka.RealtimeTrigger"

Examples

Consume a message from a Kafka topic in real time.

yaml

id: kafka_realtime_trigger
namespace: company.team

tasks:
  - id: log
    type: io.kestra.plugin.core.log.Log
    message: "{{ trigger.value }}"

triggers:
  - id: realtime_trigger
    type: io.kestra.plugin.kafka.RealtimeTrigger
    topic: test_kestra
    properties:
      bootstrap.servers: localhost:9092
    serdeProperties:
      schema.registry.url: http://localhost:8085
      keyDeserializer: STRING
      valueDeserializer: AVRO
    groupId: kafkaConsumerGroupId

Properties

`groupId`

Type: string
Dynamic: ✔️
Required: ✔️

`keyDeserializer`

Type: string
Dynamic: ✔️
Required: ✔️
Default: STRING
Possible Values:
- STRING
- INTEGER
- FLOAT
- DOUBLE
- LONG
- SHORT
- BYTE_ARRAY
- BYTE_BUFFER
- BYTES
- UUID
- VOID
- AVRO
- JSON

`properties`

Type: object
SubType: string
Dynamic: ✔️
Required: ✔️

`valueDeserializer`

Type: string
Dynamic: ✔️
Required: ✔️
Default: STRING
Possible Values:
- STRING
- INTEGER
- FLOAT
- DOUBLE
- LONG
- SHORT
- BYTE_ARRAY
- BYTE_BUFFER
- BYTES
- UUID
- VOID
- AVRO
- JSON