Hi Xiaochuan,
Is there any exception in your custom SystemConsumer? Or, are you saying
that your consumer is being interrupted externally?
The entire log will be helpful.
Thanks,
Jagdish
On Mon, Oct 30, 2017 at 9:14 AM, XiaoChuan Yu wrote:
> Hi,
>
> I'm trying to debug some problem with a Sam
Hi,
I'm trying to debug some problem with a Samza job that loads data from a
Cassandra database into Kafka via a custom System implementation.
The System makes use of BlockingEnvelopeMap.
What I see in the logs is InterruptedException from put calls from the
class that inherited BlockingEnvelopeM
