config.toml

[sources.s_kafka]
  type = "kafka" # required
  bootstrap_servers = "mykafka:9600" # required
  group_id = "vector_test" # required
#   key_field = "message_key" # optional, no default
  topics = ["my_topic"] # required


[sinks.o_elastic]
  type = "elasticsearch" # required
  inputs = ["s_kafka"] # required
  auth.strategy = "aws"
  # aws.region = "us-east-1"
  compression = "none" # optional, default

  healthcheck = true # optional, default
  host = "https://aws_es_endpoint:443" # optional, no default
  index = "vector-%F" # optional, default

errors.log

May 18 17:01:16.599 ERROR vector: Configuration error: "/tmp/vector/config.toml": unknown field `aws`, expected one of `host`, `index`, `doc_type`, `id_key`, `compression`, `encoding`, `batch`, `request`, `auth`, `headers`, `query`, `tls` for key `sinks.o_elastic`
#
#
#
May 18 17:02:34.184  INFO vector::topology: Running healthchecks.
May 18 17:02:34.303 ERROR vector::topology::builder: Healthcheck: Failed Reason: Unexpected status: 403 Forbidden
May 18 17:02:34.303 ERROR vector::topology: Sinks unhealthy.