authorjapps / authorjapps/hello-kafka-stream-testing

kafka streams headers in the produce step

Open
#1 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
27
Forks
21
PR merge metrics
No merged PRs in 30d

Description

I think it is not possible to define headers in the producer json. Something like this:
```json
"steps": [
{
"name": "produce_step",
"url": "kafka-topic:xxxx",
"operation": "produce",
"request": {
"records": [
{
**"headers": [
{"type": "aaa"}
],**
"key": "577152c4-26d2-4479-ae05-a7272fa81eea",
"value": "{\"eventId\":\"577152c4-26d2-4479-ae05-a7272fa81eea\"}"
}
]
},
"assertions": {
"status": "Ok"
}
```

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by locating the Kafka produce-step handling and the JSON request model used for records. Check how producer record fields are mapped, then determine the expected header representation and add coverage showing that headers are accepted and sent with produced records.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, kafka
Domain
stream-processing, testing
Issue type
Feature
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.