docs: protected void checkErroneous() throws Exception {
  		Exception e = asyncException;
  		if (e != null) {
  			// prevent double throwing
  			asyncException = null;
  			throw new Exception("Failed to send data to Kafka: " + e.getMessage(), e);
  		}
  	}