Hi, Vadim,
Glad that you figured out. Please let us know if you have further questions.
-Yi
On Wed, Mar 2, 2016 at 6:57 PM, Vadim Chekan wrote:
> Never mind, I forgot to "listen" to new metrics in my reporter, so those
> metrics which were created immediately worked fine, and those which were
Hi, Jose,
Great! I am looking forward to the patch! Could you open an RB to the JIRA?
Thanks a lot!
-Yi
On Wed, Mar 2, 2016 at 2:31 PM, José Barrueta wrote:
> Hi guys,
>
> At Stormpath, we made a custom samza 10 version merging SAMZA-41 into it,
> it's working well, so we are thinking to upda
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/43732/
---
(Updated March 3, 2016, 6:58 p.m.)
Review request for samza.
Changes
---
Stream name is the name of the topic that you are consuming from. (and the
topic want to reset).
On Thu, Mar 3, 2016 at 8:49 AM, Jeff Ramin
wrote:
>
> Thank you!
>
> One more question - for the config provided below:
>
> systems.system-name.streams.stream-name.samza.reset.offset = true
> systems
Thank you!
One more question - for the config provided below:
systems.system-name.streams.stream-name.samza.reset.offset = true
systems.system-name.streams.stream-name.samza.offset.default = oldest
How do I determine what the "stream-name" is? I'm running the
hello-samza example,
which consu
https://issues.apache.org/jira/browse/SAMZA-255 is the JIRA for rewinding a
stream without restarting.
On Thu, Mar 3, 2016 at 8:44 AM, Jagadish Venkatraman wrote:
> You can use the checkpoint tool to publish the desired offset, and restart
> your job. It will pick up the new offset.
> Please loo
You can use the checkpoint tool to publish the desired offset, and restart
your job. It will pick up the new offset.
Please look at
https://samza.apache.org/learn/documentation/0.10/container/checkpointing.html
.
On Thu, Mar 3, 2016 at 6:28 AM, Jeff Ramin
wrote:
>
> Thanks Jacob.
>
> Regarding 2
Thanks Jacob.
Regarding 2) below - is there a way to reprocess messages from an
arbitrary position,
instead of from the beginning?
On 03/01/2016 06:32 PM, Jacob Maes wrote:
A couple notes that may be helpful:
1. When you have a stateful processor that dies, the changelog is the
default mea
