Summary
Raccoon doesn't support partition keys when producing messages to a Kafka Topic. Currently, it produces the message to any random partition(ref).
This is a feature request to support the partition key for each message in the API and SDK.
Proposed solution
Enable POST /api/v1/events to support this payload !
{
"req_guid": "1234abcd",
"sent_time": {
"seconds": 1638154927,
"nanos": 376499000
},
"events": [
{
"eventBytes": "Cg4KCHNlcnZpY2UxEgJBMRACIAEyiQEKJDczZTU3ZDlhLTAzMjQtNDI3Yy1hYTc5LWE4MzJjMWZkY2U5ZiISCcix9QzhsChAEekGEi1cMlNAKgwKAmlkEgJpZBjazUsyFwoDaU9zEgQxMi4zGgVBcHBsZSIDaTEwOiYKJDczZTU3ZDlhLTAzMjQtNDI3Yy1hYTc5LWE4MzJjMWZkY2U5Zg==",
"type": "booking",
"partition_key": "some-key" // <----------------new key support
}
]
}
Additional context
Summary
Raccoon doesn't support partition keys when producing messages to a Kafka Topic. Currently, it produces the message to any random partition(ref).
This is a feature request to support the partition key for each message in the API and SDK.
Proposed solution
Enable POST
/api/v1/eventsto support this payload !{ "req_guid": "1234abcd", "sent_time": { "seconds": 1638154927, "nanos": 376499000 }, "events": [ { "eventBytes": "Cg4KCHNlcnZpY2UxEgJBMRACIAEyiQEKJDczZTU3ZDlhLTAzMjQtNDI3Yy1hYTc5LWE4MzJjMWZkY2U5ZiISCcix9QzhsChAEekGEi1cMlNAKgwKAmlkEgJpZBjazUsyFwoDaU9zEgQxMi4zGgVBcHBsZSIDaTEwOiYKJDczZTU3ZDlhLTAzMjQtNDI3Yy1hYTc5LWE4MzJjMWZkY2U5Zg==", "type": "booking", "partition_key": "some-key" // <----------------new key support } ] }Additional context