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 BlockingEnvelopeMap and then the container exiting
with code 248:
There is almost nothing else in the logs so I'm very puzzled on what could
be causing this.
Has anyone ever seen exit code 248?
Could a problem with Kafka cause something like this?