diff --git a/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/common/external/ExternalProcessLogger.java b/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/common/external/ExternalProcessLogger.java
index 1aeebe224..009a15819 100644
--- a/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/common/external/ExternalProcessLogger.java
+++ b/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/common/external/ExternalProcessLogger.java
@@ -44,10 +44,7 @@ public void run() {
             while ((line = STDERR.readLine()) != null) {
                 external_log(line);
             }
-        } catch (IOException e) {
-            log.error("Failed to read from the process STDERR.");
-            throw new KafkaException(e);
-        }
+        } catch (IOException e) { }
     }
 
     private void external_log(String line) {
diff --git a/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/streams/processor/external/ExternalProcessorSupplier.java b/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/streams/processor/external/ExternalProcessorSupplier.java
index 52051e55f..bb31f8e1f 100644
--- a/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/streams/processor/external/ExternalProcessorSupplier.java
+++ b/Utils/Dataflow/000_kafka/ru/kiae/dkb/kafka/streams/processor/external/ExternalProcessorSupplier.java
@@ -157,7 +157,11 @@ public void punctuate(long timestamp) {
             @Override
             public void close() {
                 log.info("Destroying external process.");
-                this.externalProcessor.destroy();
+                try {
+                  this.externalProcessor.destroy();
+                  this.externalProcessor.waitFor(2L, TimeUnit.SECONDS);
+                } catch (InterruptedException int_e) { }
+
             }
 
             public void start() {