OptionalauthOptionalbackfillA user-provided and managed source for backfilling data. Historical data is used when creating a training set from streaming features linked to this Kafka config.
In the future, a separate table will be maintained by
OptionalbootstrapA comma-separated list of host/port pairs pointing to Kafka cluster.
OptionalextraCatch-all for miscellaneous options. Keys should be source options or Kafka consumer options (kafka.*)
OptionalingestionConfiguration for ingesting Kafka data into a
OptionalkeySchema configuration for extracting message keys from topics. At least one of key_schema and value_schema must be provided.
OptionalnameName that uniquely identifies this Kafka config within the metastore. This will be the identifier used from the Feature object to reference these configs for a feature. Can be distinct from topic name.
OptionalsubscriptionOptions to configure which Kafka topics to pull data from.
OptionalvalueSchema configuration for extracting message values from topics. At least one of key_schema and value_schema must be provided.
Authentication configuration for connection to topics.