Folks,
We are using an external component in one of our tasks, the external component
persists some info to MySQL DB, the component reads database connection info
from a specific property file that should be available in classpath. Is there
a way I can specify custom property files as part of
Folks,
We are running a multi-node Samza cluster with multiple partitions for each
task. In one of the tasks, we would like to send output to two different tasks
and the payload also is different. Below is the code that does it
messageCollector.send(new OutgoingMessageEnvelope(output_stream_1,
input streams does this task consume and how are they partitioned?
Garry
-Original Message-
From: Balusamy, Elangovan [mailto:elangovan.balus...@altisource.com]
Sent: 02 September 2015 08:19
To: dev@samza.apache.org
Cc: Chandra, Saurabh
Subject: One task sending payload to multiple output
to the choice on the
outgoing message partition key, which is the only deciding factor for which
partition of a topic the message is sent to.
-Yi
On Wed, Sep 2, 2015 at 12:58 AM, Balusamy, Elangovan <
elangovan.balus...@altisource.com> wrote:
> The task consumes from one stream with 2
