Corrects TimeoutException for the OPALPlugin.
@@ -28,10 +28,10 @@ import java.util.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
-import org.apache.kafka.common.errors.TimeoutException;
import org.json.JSONException;
import org.json.JSONObject;
import org.pf4j.Extension;
