SamzaContainer NullPointerException for read byte[] topic from Kafka

Dear All: I tried to consumer kafka topic "cnr-proto" in Java. It got the SamzaContainer NullPointerException as below. The messages can be shown by command line correctly "deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic cnr-proto" My Key

Re: Detecting "done" on a bounded input dataset

Hi Yi, Detecting both scenarios will be useful. Scenario 1: To detect that the reprocessing job has "caught up" with the stream, as described by Jay Kreps here , so that we can make the app point to the new DB and tear dow

Re: Detecting "done" on a bounded input dataset

Hi, Kishore, First I want some clarification on your use case. 1) Scenario 1: you still want the Samza jobs continuously running, while simply want to detect the end of a certain stream. On detection, do you need to unsubscribe from the stream? Or you are still OK receiving more messages from the

Detecting "done" on a bounded input dataset

Hi, Our data processing pipeline consists of a set of Samza jobs, that form a DAG. Sometimes, we have to throw finite datasets into the Kafka topic that acts as the entry point to the pipeline. Given that different Samza jobs in the DAG could have varying latencies in terms of processing the recor