Review Request 40421: SAMZA-754: fix the null oldestOffset issue in empty topics

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/40421/ --- Review request for samza, Yan Fang, Chinmay Soman, Chris Riccomini, and Navina

Sample code or tutorial for writing/reading Avro type message in Samza

Dear All: Do you know where I can find the tutorial or sample code for writing Avro type message to Kafka and reading Avro type message from Kafka in Samza? I am wondering how should I serialized GenericRecord to byte and deserialized it? Your comments/suggestion are highly

Re: Sample code or tutorial for writing/reading Avro type message in Samza

Hi Selina, If you want to use Confluent's schema registry for Avro, then I have an example in this repo: https://github.com/theduderog/hello-samza-confluent Cheers, Roger On Tue, Nov 17, 2015 at 12:32 AM, Selina Tech wrote: > Dear All: > Do you know where I can

Sporadic errors in JobRunner

Hi, getting things working on samza 0.10.0 finally :) I’m seeing the following error about 1/4 of the time from run-job.sh when starting jobs: [yarnmaster01] out: 2015-11-17 14:56:00 KafkaSystemAdmin$ [INFO] Got metadata: Map(__samza_coordinator_t-key-grouper_dev -> SystemStreamMetadata

Review Request 40407: Added gauge metric to measure state store restoration time

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/40407/ --- Review request for samza, Yan Fang, Jake Maes, Jagadish Venkatraman, Xinyu Liu,

Re: Can't get all stored values via range iterator

Just want to update you on this one. After some time spent in debugging I found that the actual problem was a piece of our code that was calling next() on a range iterator twice :(. After removing the duplicate call everything works as expected. Thank you! Alex On Mon, Nov 16, 2015 at 10:45 PM,