Optional
additionalA container for additional, undeclared properties. This is a holder for any undeclared properties as specified with the 'additionalProperties' keyword in the OAS document.
Consumer group ID used by the Kafka client.
The unique identifier for this component. Used to reference this component in other parts of the pipeline (e.g., as input to downstream components).
Optional
librdkafkaOptional list of advanced Kafka client configuration options, defined as key-value pairs.
Optional
saslSpecifies the SASL mechanism for authenticating with a Kafka cluster.
Optional
tlsConfiguration for enabling TLS encryption.
A list of Kafka topic names to subscribe to. The source ingests messages from each topic specified.
The source type. The value should always be kafka
.
Generated using TypeDoc
The
kafka
source ingests data from Apache Kafka topics.