You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "wzhramc (via GitHub)" <gi...@apache.org> on 2025/09/04 15:42:04 UTC
[PR] [improve][pip] PIP-437: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]
wzhramc opened a new pull request, #24703:
URL: https://github.com/apache/pulsar/pull/24703
### Motivation
This PIP proposes extending Pulsar Functions with configuration-based automatic transaction support to enable exactly-once processing semantics. Currently, Pulsar
Functions cannot publish to multiple topics transactionally, which is a significant limitation for use cases requiring atomic multi-topic operations.
### Modifications
The implementation will allow functions to atomically process input messages and publish to multiple output topics within a single transaction without requiring code
changes to the function implementation. This will be achieved through:
- Adding transaction configuration options to FunctionConfig
- Modifying JavaInstanceRunnable to support auto-transactions
- Enhancing ContextImpl to track and use transactions
- Adding metrics for monitoring transaction usage in functions
### Verifying this change
- [ ] Make sure that the change passes the CI checks.
This change will add tests and can be verified through:
- Unit tests for transaction-enabled function execution
- Integration tests for end-to-end transaction processing
### Does this pull request potentially affect one of the following parts:
- [x] The public API
- [x] The metrics
### Documentation
- [ ] `doc-required` <!-- Will update docs after implementation -->
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]
Posted by "wzhramc (via GitHub)" <gi...@apache.org>.
wzhramc closed pull request #24703: [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping
URL: https://github.com/apache/pulsar/pull/24703
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [improve][pip] PIP-437: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #24703:
URL: https://github.com/apache/pulsar/pull/24703#issuecomment-3254313675
@wzhramc Please add the following content to your PR description and select a checkbox:
```
- [ ] `doc` <!-- Your PR contains doc changes -->
- [ ] `doc-required` <!-- Your PR changes impact docs and you will update later -->
- [ ] `doc-not-needed` <!-- Your PR changes do not impact docs -->
- [ ] `doc-complete` <!-- Docs have been already added -->
```
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org