使用embedded agent，除了不知道要做什么之外，您得到的情况是相同的：

try {
  agent.put(event);
} catch (EventDeliveryException e) {
  // ???      
}

您可以停止代理，然后重新启动它—但是您需要一个同步块（或 ReentrantReadWriteLock ，在“读取”线程时不阻塞线程 client 字段）。但由于我不是FlumeMaven，我不能告诉你哪一个更好。
例子：

class MyClass {
  private final ReentrantReadWriteLocklock;
  private final Lock readLock;
  private final Lock writeLock;
  private RpcClient client;
  private final String hostname;
  private final Integer port;

  // Constructor
  MyClass(String hostname, Integer port) {
    this.hostname = Objects.requireNonNull(hostname, "hostname");
    this.port = Objects.requireNonNull(port, "port");
    this.lock = new ReentrantReadWriteLock();
    this.readLock = this.lock.readLock();
    this.writeLock = this.lock.writeLock();
    this.client = buildClient();
  }

  private RpcClient buildClient() {
    return RpcClientFactory.getDefaultInstance(hostname, port);
  }    

  public void sendDataToFlume(String data) {
    // Create a Flume Event object that encapsulates the sample data
    Event event = EventBuilder.withBody(data, Charset.forName("UTF-8"));

    // Send the event
    readLock.lock(); // lock for reading 'client'
    try {      
      try {
        client.append(event);
      } catch (EventDeliveryException e) {
        writeLock.lock(); // lock for reading/writing client
        try {
          // clean up and recreate the client
          client.close();
          client = null;
          client = buildClient();
        } finally {
          writeLock.unlock();
        }
      }
    } finally {
      readLock.unlock();
    }
  }
}

此外，示例将丢失事件，因为它不会被发回。某种循环+最大重试可能会达到以下效果：

int i = 0;
for (; i < maxRetry; ++i) {
  try {
    client.append(event);
    break;
  } catch (EventDeliveryException e) {
      // clean up and recreate the client
      client.close();
      client = null;
      client = RpcClientFactory.getDefaultInstance(hostname, port);
      // Use the following method to create a thrift client (instead of the above line):
      // this.client = RpcClientFactory.getThriftInstance(hostname, port);
  }
}
if (i == maxRetry) {
  logger.error("flume client is offline, loosing events {}", event);
}

这是想法，但我不认为这应该是用户（例如：us）的任务，而是客户机或代理中的一个选项，用于存储由于此类错误而无法处理的事件。