Inputs
Last updated: 1 minute read.
An input is a source of data piped through an array of optional processors:
input:
label: my_kafka_input
kafka:
addresses: [ localhost:9092 ]
topics: [ foo, bar ]
consumer_group: foogroup
# Optional list of processing steps
processors:
- avro:
operator: to_json
Brokering
Only one input is configured at the root of a Tyk Streams config. However, the root input can be a broker which combines multiple inputs and merges the streams:
input:
broker:
inputs:
- kafka:
addresses: [ localhost:9092 ]
topics: [ foo, bar ]
consumer_group: foogroup
- http_client:
url: https://localhost:8085
verb: GET
stream:
enabled: true
Labels
Inputs have an optional field label that can uniquely identify them in observability data such as metrics and logs.