function-mesh
function-mesh copied to clipboard
The serverless framework purpose-built for event streaming applications.
https://github.com/streamnative/function-mesh/issues/131 added the inferring `typeClassName` feature to Pulsar Functions Java runtime, but the webhook prevents the user from providing `null` to `typeClassName`. We will need to fix it by removing...
The current `conditions` field looks like the following: ```go type ResourceCondition struct { Condition ResourceConditionType `json:"condition,omitempty"` Status metav1.ConditionStatus `json:"status,omitempty"` Action ReconcileAction `json:"action,omitempty"` } ``` If we use Kubernetes-format [Conditions](https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle/#pod-conditions), we...
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to...
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to...
Hi, I'm trying to use authentication for a java function with the common use of `Secrets` to store the JWT token needed to access pulsar. ### authSecret works As I...
1. When I enable effectively_once and deploy the function in k8s, for example, after deploying 5 pods, when one of my pods crashes, his subscription will be transferred to other...
apache/pulsar#16740 added a transform function for the sink connector, and it contains changes about the function details, function mesh should support this feature.
Function Mesh releases various runner images across Pulsar 2.8 to 2.11 (3.0 is coming soon), with a lot of runner images, the users will need to keep updating the runner...
Does function-mesh support ReplicatedSubscriptionsUpdate in consumer or producer? I have read functionmesh document and deployed Pulsar Function on functionmesh enabled cluster. By the way, I'd like to know any document...