GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/459
Initial version for in memory system.
Getting the PR out to unblock sanil.
Pending tasks
1. Add documentation
2. Add more tests
3. Currently initialization of the stream happens using createStream on
admin. We need to find a way to expose the same functionality to low level
users.
4. To populate the initial stream, clients need to get a handle on
producer and produce the messages. Alternatively, we can support serialization
of source data and pass it as config to the system to initialize. We have a
hook in place for this but not implemented it completely.
5. Clean up consumed data on the buffer based on the lowest offsets of
the consumers.
I will create JIRAs for all the pending tasks and fix them iteratively.
@xinyuiscool ^^
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bharathkk/samza single-node-testing
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/459.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #459
----
commit 3580632fbd955a101060ea390994856c0802d68f
Author: Bharath Kumarasubramanian <bkumaras@...>
Date: 2018-02-16T01:42:23Z
Initial version for in memory system.
----
---
