goutamadwant commented on issue #10753: URL: https://github.com/apache/seatunnel/issues/10753#issuecomment-5337757630
@DanielLeens @davidzollo I prepared the Google Pub/Sub sink side #11877 as the first slice for #10753. - publishes JSON or delimited text payloads - supports ADC, a service account key file, and the Pub/Sub emulator - waits for outstanding publishes during checkpoints and shutdown - reports publish failures back to the task - includes JDK 8 and 11 unit coverage, documentation, registrations, and emulator E2E coverage across Flink, Zeta, and Spark I kept source support separate because subscriber acknowledgements and checkpoint recovery need their own design and tests. Let me know if you have any suggestions. thanks! -- 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]
