Re: Beam/Samza Ensuring At Least Once semantics

2019-07-12 Thread Lukasz Cwik
"Audo, > Nicholas" , "Cesar, Scott" < > scott_ce...@intuit.com>, "Ho, Tom" , " > d...@samza.apache.org" > *Subject: *Re: Beam/Samza Ensuring At Least Once semantics > > > > This email is from an external sender. > > >

Re: Beam/Samza Ensuring At Least Once semantics

2019-07-10 Thread Lukasz Cwik
XX, > part=0, offset=106, val: k”, and after some time I see ‘k’ in the output > topic. So, the records with values ‘g’, ‘h’, ‘I’, ‘j’ are NOT processed. > > > > > > Based on these results I’m incline to conclude that Beam with Samza runner > does NOT provides 'at least once'

Re: Beam/Samza Ensuring At Least Once semantics

2019-07-09 Thread Benenson, Mikhail
enenson From: "LeVeck, Matt" Date: Monday, July 1, 2019 at 5:28 PM To: "Deshpande, Omkar" , "Benenson, Mikhail" , Xinyu Liu , Xinyu Liu , Samarth Shetty , "Audo, Nicholas" Subject: Beam/Samza Ensuring At Least Once semantics We’re seeing some behavior