Neng Lu
Neng Lu
I'll update it this week
@keenborder786 This config request translates into implementing the `SupportsAdmissionControl` interface. We will work on that during Q2
@keenborder786 we can leave it open and close it when the implementation is done
close due to inactivity.
@DutchDave @acherla our team member is looking into this issue. Will provide update soon
@huijunw Those metrics are calculated on the run. You can check the commit I mentioned to see how they are calculated.
@tisonkun I think the `IdentitySerDe` should be called `SimpleSerDe` and the doc for it should clearly say it will pass (string, int, float, complex, and bytes) values as it is...
Hi @scarlier, we have identified the issue and will push a fix soon.
@akshay-habbu 1. Where do you access the UI? It's not StreamNative Cloud Console. 2. For the `Subscription does not exist` issue, it may be caused by some Pulsar side configuration....
@akshay-habbu Just FYI, during the spark job execution, it spawns new consumer/reader to consume messages from the last committed position. That's why you may observe some backlog. Do you see...