Can you share link to the source?
בתאריך יום ד׳, 23 בפבר׳ 2022, 6:52, מאת bo yang :
> We do not have SaaS yet. Now it is an open source project we build in our
> part time , and we welcome more people working together on that.
>
> You could specify cluster size (EC2 instance type and number of i
If you are using kafka direct connect api it might be committing offset
back to kafka itself
בתאריך יום ה׳, 7 ביוני 2018, 4:10, מאת licl :
> I met the same issue and I have try to delete the checkpoint dir before the
> job ,
>
> But spark seems can read the correct offset even though after the
