From 9e21e3d2ee3d7ae1459b7249bdb408c4f3228994 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 15 Mar 2026 16:55:13 +0100
Subject: [PATCH] =?utf8?q?Die=20begrenzte=20Queue=20mit=20Blocking=20wird?=
 =?utf8?q?=20nicht=20mehr=20ben=C3=B6tigt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../java/de/juplo/kafka/ExampleProducer.java  | 27 +------------------
 1 file changed, 1 insertion(+), 26 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index b4dfebb9..24add8f8 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -20,14 +20,7 @@ public class ExampleProducer
   private final String topic;
   private final Producer<String, String> producer;
 
-  private final ExecutorService executor = new ThreadPoolExecutor(
-    1,
-    1,
-    60L,
-    TimeUnit.MILLISECONDS,
-    new ArrayBlockingQueue<>(MAX_PENDING_MESSAGES),
-    new BlockingRejectedExecutionHandler()
-  );
+  private final ExecutorService executor = Executors.newSingleThreadExecutor();
   private final Semaphore semaphore = new Semaphore(MAX_PENDING_MESSAGES);
   private volatile boolean running = true;
   private volatile boolean done = false;
@@ -189,22 +182,4 @@ public class ExampleProducer
 
     instance.run();
   }
-
-
-  static class BlockingRejectedExecutionHandler implements RejectedExecutionHandler
-  {
-
-    @Override
-    public void rejectedExecution(Runnable runnable, ThreadPoolExecutor executor)
-    {
-      try
-      {
-        executor.getQueue().put(runnable);   // blockiert bis Platz frei ist
-      }
-      catch (InterruptedException e) {
-        Thread.currentThread().interrupt();
-        throw new RejectedExecutionException(e);
-      }
-    }
-  }
 }
-- 
2.39.5