Set message ordering key for Google Pubsub
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
Message ordering is currently not supported on the producer side.
[https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessage.java#L44](https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessage.java#L44)
Imported from Jira [BEAM-12007](https://issues.apache.org/jira/browse/BEAM-12007). Original Jira may contain additional context.
Reported by: victuos.
Contributor guide
Research direction
Start with sdk/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessage.java at the linked location, then trace how producer-side messages are constructed. Done means producer messages support a Google Pub/Sub message ordering key, with the relevant existing tests updated or added as needed.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- google-cloud, java
- Domain
- distributed-systems
- Issue type
- Feature
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 45/100