java/scala中较新的8.2 producer（异步producer）为每条消息传递了一个回调方法。您可以尝试处理回调中的失败。。可能重试。回调方法采用两个参数（exception和messagemetatdata）。任何时候都只能设置一个。meatadata是在您的消息成功发送时设置的，以防出错。
使用sync producer，您必须设置max.retries和@leshkin指出的其他配置。

请在生产者中添加异常处理：

try{
      Producer logic
}
catch (Exception ex) {
      String errorMsg = "Failed to publish events";
      logger.error("Failed to publish events", ex);
      result = Status.BACKOFF;

如果还是不行，请告诉我。

这取决于生产者配置（生产者配置）
特别注意参数：

(METADATA_FETCH_TIMEOUT_CONFIG, 60000),
  (TIMEOUT_CONFIG, 10000),
  (RETRY_BACKOFF_MS_CONFIG, 100),
  (RECONNECT_BACKOFF_MS_CONFIG, 1000)

您一定要更改有关设置的参数。所有这些参数都会影响生产者的行为。