Can not publish pubsub message with ordering key

[TRUSTMEIMJEDI]

https://github.com/apache/beam/blame/7f04c4f07f2698f823953902bfb79fc7cb6e1584/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java#L1480

Because of this code it is not possible to send pubsub message with ordering key due to the fact that coder that is provided from input is then overridden by line 1480. This problem occurs since 2.48 version in version 2.47 everything is fine.

Doesn't matter if coder is registered explicitly
like this
.setCoder(PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder.of())
or like this
pipeline.getCoderRegistry().registerCoderForClass(PubsubMessage.class, PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder.of());

[ahmedabu98]

#31608 should add support for this

[sjvanrossum]

@TRUSTMEIMJEDI to elaborate, the applied coder is not the only issue that would prevent publishing messages with ordering keys. See the PR referenced above for more details.

FYI if you use Beam on Dataflow then the default behavior is to use an alternative implementation of PubsubIO's transforms and that implementation won't immediately benefit from the changes in the PR referenced above.

[aprochko]

@TRUSTMEIMJEDI this is now supported since 2.65.0