Skip to content

Support extract-headers kafka message transform #1175

@jfallows

Description

@jfallows

Suggested syntax.

  kafka_cache_server:
    type: kafka
    kind: cache_server
    options:
        topics:
          - name: my-transformed-topic
            transforms:
              - extract-headers:
                'zilla:identity': ${message.value.user_id}
...

Metadata

Metadata

Assignees

Labels

enhancementNew feature or request

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions