[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766259#comment-17766259
]
Vetle Leinonen-Roeim commented on FLINK-32727:
----------------------------------------------
Came here to open a discussion about this, we also have this need ... and I
also have something working for this! :D
> Adding capability of setting Attributes in Google Pub/Sub sink
> --------------------------------------------------------------
>
> Key: FLINK-32727
> URL: https://issues.apache.org/jira/browse/FLINK-32727
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Google Cloud PubSub
> Reporter: Yinghai Zhao
> Priority: Major
>
> Currently the Google PubSub Sink can only publish messages with data in body.
> To take full advantage of Google PubSub, having the ability to set attributes
> is important, so subscriptions can filter on attributes and consume part of
> the event stream.
> Google Doc on
> [message|https://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage]
> and
> [subscription.|https://cloud.google.com/pubsub/docs/subscription-message-filter]
>
> I have a basic idea on this and had a patch working locally. Wondering how I
> can incorporate this back to the official connector.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
