Affan255 opened a new issue, #31884: URL: https://github.com/apache/beam/issues/31884
I am trying to read from cloud pub/sub subscription using PubSubIO.Reader. The subscription has dead lettering configured properly. I tried to read from Pub/Sub in two ways from the SAME subscription of SAME topic in two ways: 1. Cloud PubSub way. In this case, "googclient_deliveryattempt" attribute is present when message is read. 2. Apache Beam way using PubSubIO. In this case, "googclient_deliveryattempt" attribute in not present when message is read. Although, if a message is published from PubSub with custom attributes, they do show up in attributes map in Apache Beam. Please help me in this issue. In case, if resolving this issue takes time, suggest a workaround to achieve this. I have attached the code to read from PubSub from both ways for reference. <img width="1512" alt="Beam_Read" src="https://github.com/user-attachments/assets/b70130af-8d12-4569-9e90-fed9484b6cd5";> <img width="1512" alt="PubSub_Read" src="https://github.com/user-attachments/assets/1dfa44f6-a205-496d-aebd-8d49fdd27d5a";> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
