[CONF] Apache Samza > SEP-8: Add in-memory system consumer & producer

[Bharath Kumarasubramanian (Confluence)]

Title: Message Title

Bharath Kumarasubramanian commented on a page

Re: SEP-8: Add in-memory system consumer & producer Done. I agree it might be not be necessary for it to be configurable for test setting. If we were to use the in-memory system outside test setting, we would need to limit the queue size and we can go with the default for now. It does work for SteamTask as well. I have updated the test cases. Manual checkpointing would result in the desired behavior for everything else except the in-memory system where it will just be a no-op. Updated the test plan. It is possible for the change-log to use in-memory system though its managed by samza for the users. In order to inspect the change-log, we would need StoreDescriptor similar to input and output StreamDescriptor. Yes it does. Will do Reply • Like

Stop watching space • Manage notifications This message was sent by Atlassian Confluence 5.8.17