david-streamlio opened a new issue #10269: URL: https://github.com/apache/pulsar/issues/10269
**Describe the bug** When an Error or Exception occurs in write() method of the sink, the error is logged but no actions are performed. The reason why is the logic that was added to enabled async processing in functions prevents errors in the sink to be bubbled up: **To Reproduce** Steps to reproduce the behavior: 1. Go to '...' 2. Click on '....' 3. Scroll down to '....' 4. See error **Expected behavior** When an exception occurs inside the write() method of a Sink, the error should be logged AND an exception thrown to notify the user of the issue rather than failing silently. This applies to both sync and async mode. **Screenshots** N/A **Additional context** None -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
