Producer.throwException

Throws an exception in the producer task. This is used to pass the connection exceptions to the user.

class Producer
void
throwException
(
Exception ex
)

Meta