Skip to content

Support Kafka Partition Key #95

@whoAbhishekSah

Description

@whoAbhishekSah

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions