Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support Kafka headers in consumer/producer #690

Open
skateinmars opened this issue Jun 26, 2023 · 0 comments
Open

Support Kafka headers in consumer/producer #690

skateinmars opened this issue Jun 26, 2023 · 0 comments
Labels

Comments

@skateinmars
Copy link

Hello,

I would like for kafka headers to be supported, both reading them when consuming or when producing messages.
Sarama already supports it, cf https://github.com/shopify/sarama/blob/v1.20.1/async_producer.go#L177C12-L177C24 on the producer side for instance.

The yaml config could be extended:

name: My Kafka testsuite
version: "2"
testcases:
- name: Kafka test
  description: Test Kafka
  steps:
  - type: kafka
    clientType: producer
    withSASL: true
    withTLS: true
    user: "{{.kafkaUser}}"
    password: "{{.kafkaPwd}}"
    addrs:
      - "{{.kafkaHost}}:{{.kafkaPort}}"
    messages:
    - topic: test-topic
      key: "{{.entityID}}"
      headers:
        - key: "X-Internal-ID"
          value: "0168a1e7-cdc6-4820-981b-f6e381b59003"
      value: |
        {
          "Foo": "Bar"
        }

Thanks for your work on this project!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants