Re: Checkpoint tool not working

I'm using Samza 0.9.1. Lukas On 10/29/15, Yi Pan wrote: > Hi, Lukas, > > Which version of checkpoint-tool are you using? > > -Yi > > On Thu, Oct 29, 2015 at 5:39 PM, Lukas Steiblys > wrote: > >> Hello, >> >> I’m trying to write the checkpoints for a Samza task supplying these >> arguments to th

Re: Checkpoint tool not working

Hi, Lukas, Which version of checkpoint-tool are you using? -Yi On Thu, Oct 29, 2015 at 5:39 PM, Lukas Steiblys wrote: > Hello, > > I’m trying to write the checkpoints for a Samza task supplying these > arguments to the checkpoint tool: > > bin/checkpoint-tool.sh > --new-offsets=file:///checkpo

Checkpoint tool not working

Hello, I’m trying to write the checkpoints for a Samza task supplying these arguments to the checkpoint tool: bin/checkpoint-tool.sh --new-offsets=file:///checkpoints/client-metrics.properties --config-path=file:///checkpoints/task.properties However, it doesn’t actually write the checkpoints

Re: Re: questions of partition and task of Samza

Hi, Yan: Thanks a lot for your answer. Sincerely, Selina On Mon, Oct 26, 2015 at 8:03 PM, Yan Fang wrote: > Hi Selina, > > > Your understanding is correct. Yes, you "need to consumer the original > input and send it back to Kafka and reset the* Key to departmentName *and > then consume it

Re: Hello Samza tutorial

Hi, Rohit: You might like to check deploy/kafka/logs/kafka.log file. Sincerely Selina On Thu, Oct 29, 2015 at 9:24 AM, Rohit Upadhyaya wrote: > Hi, > > I am following the "Hello Samza" tutorial here: > http://samza.apache.org/startup/hello-samza/0.9/ .Following all the steps > I > get an e

Hello Samza tutorial

Hi, I am following the "Hello Samza" tutorial here: http://samza.apache.org/startup/hello-samza/0.9/ .Following all the steps I get an error/warn (no brokers found when trying to rebalance.) when I try to consume the topic using the command deploy/kafka/bin/kafka-console-consumer.sh --zookeeper