apache / apache/beam

[FEATURE REQUEST] Add the ability to set custom attributes on the PubsubIO writeAvros method

Open
#26,824 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

The writeAvros() method on the PubsubIO connector doesn't accept attributes, instead you have to use writeMessages(), which does accept attributes, but requires the user to convert the payload into an Avro format and then serializing it into bytes[].

The request is for the PubsubIO writeAvros method could accept setting custom attributes.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.