diff --git a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
index c4f0ff4526f7c932e6fac6318ea442963bc60cd4..335259ed15996024c25f7c0bf5c8fa13ccc69a4e 100644
--- a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
+++ b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
@@ -109,19 +109,20 @@ final class TCPCountingReader extends AbstractReaderPlugin {
 	private final ILookup<String> stringRegistry = new Lookup<String>();
 
 	final AtomicInteger counter = new AtomicInteger(0);
+	final ScheduledExecutorService executorService;
 
 	public TCPCountingReader(final Configuration configuration, final IProjectContext projectContext) {
 		super(configuration, projectContext);
 		this.port1 = this.configuration.getIntProperty(CONFIG_PROPERTY_NAME_PORT1);
 		this.port2 = this.configuration.getIntProperty(CONFIG_PROPERTY_NAME_PORT2);
+		this.executorService = new ScheduledThreadPoolExecutor(1);
 	}
 
 	@Override
 	public boolean init() {
-		final ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
-		executorService.scheduleAtFixedRate(new Runnable() {
+		this.executorService.scheduleAtFixedRate(new Runnable() {
 			public void run() {
-				LOG.info("Records/s: " + TCPCountingReader.this.counter.getAndSet(0));
+				System.out.println("Records/s: " + TCPCountingReader.this.counter.getAndSet(0));
 			}
 		}, 0, 1, TimeUnit.SECONDS);
 
@@ -196,6 +197,7 @@ final class TCPCountingReader extends AbstractReaderPlugin {
 
 	public void terminate(final boolean error) {
 		LOG.info("Shutdown of TCPReader requested.");
+		this.executorService.shutdown();
 	}
 }