Как обращаться и издеваться над InterruptedException у производителя Kafka

Question

Производитель Kafka возвращает InterruptedException при создании сообщения в некоторых случаях. Я хочу знать о способе обработки и насмешек InterruptedException для повышения производительности модульного тестирования производителем Kafka. Внизу добавлен мой код производителя. Спасибо.

public void MyProducer(String msg, String key)
      throws ExecutionException, InterruptedException {
    // statements....
  }