Hi Jay,
Thanks for your answer.
> However a few things have changed since that original design:
> 1. We now have the additional use cases of copycat and Samza
> 2. We now realize that the assignment strategies don't actually necessarily
> ensure each partition is assigned to only one consumer--t
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/
---
Review request for samza.
Repository: samza
Description
---
Moved the cr
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/
---
(Updated July 3, 2015, 9:58 a.m.)
Review request for samza.
Repository: samza
Any answer on how to get all the kv values and reinitialise the kv store?
Had one more question on implementing sliding window.
If i use a kv store like rocksdb, and I use yarn (say 3 node cluster), the
job that it runs to aggregate gets distributed as well and I am guessing
the aggregation numbe
Hey Yi,
Yeah let me try to be more concrete. Any partition assignment management
requires two things
G - a group of consumer instances
f - a function f(G) that yields the mapping of partitions to consumer
instances
The hard thing is to determine G, this is what requires the heartbeats,
coordi
Hey Gianmarco,
To your broader point, I agree that having a close alignment with Kafka
would be a great thing in terms of adoption/discoverability/etc. There
areas where I think this matters a lot are:
1. Website and docs: ideally when reading about Kafka you should be able to
find out about Samza
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35933/
---
(Updated Julho 3, 2015, 11:05 p.m.)
Review request for samza.
Repository: sam
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35933/#review90373
---
samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDb
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35933/
---
(Updated Julho 4, 2015, 12:13 a.m.)
Review request for samza.
Repository: sam
