You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by Stuart Perks <st...@gmail.com> on 2020/12/19 20:27:55 UTC

Samza Test

I have a Samza application that writes into a table back by a changelog. 

Is there any way to assert on the data stored in the table using Samza test using the InMemorySystemDescriptor after data has been run into the topology? 

Thanks

Re: Samza Test

Posted by Sanil Jain <sa...@gmail.com>.

Hi Stuart,

Please refer to this example to test your Samza app with LocalTable:
https://github.com/apache/samza/blob/master/samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableWithSideInputsEndToEnd.java#L59

Thanks
Sanil

On Sat, 19 Dec 2020 at 12:28, Stuart Perks <st...@gmail.com> wrote:

> I have a Samza application that writes into a table back by a changelog.
>
> Is there any way to assert on the data stored in the table using Samza
> test using the InMemorySystemDescriptor after data has been run into the
> topology?
>
> Thanks