Unable to extract labels from loki sink in vector

[surekha3]

A note for the community

• Please vote on this issue by adding a 👍 reaction to the original issue to help the community and maintainers prioritize this request
• If you are interested in working on this issue or have submitted a pull request, please leave a comment

Problem

Trying to collect kafka logs using vector latest version and sending to loki. But unable to extract any labels from loglines. when given under labels i.e.,
labels:
env: "{{ env }}"
It's stating function env not found error though it's present within logline. Please help asap. Below is the config used
transforms:
extract_transform:
type: remap
inputs:

• kafka_logs
  source: |
  .topic = to_string!(.topic)
  . = parse_json!(.message)
  .host = .parsed.tags.host
  sinks:
  loki_sink:
  type: loki
  inputs:
• extract_transform
  endpoint: http://loki-nob-gateway/
  encoding:
  codec: "json"
  compression: none
  healthcheck: false
  labels:
  job: "kafka"
  topic: "{{ topic }}"
  host: "{{ host }}"

Configuration

Version

0.45.0

Debug Output

Example Data

No response

Additional Context

No response

References

No response