diff --git a/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java b/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java
index c7a850a1..724fc3f6 100644
--- a/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java
+++ b/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java
@@ -69,7 +69,6 @@ Future<List<KafkaProducerRecord<String, String>>> buildRecordsAsync(String topic
                 return Future.failedFuture(new ValidationException("Missing 'records' array"));
             }
             return vertx.executeBlocking(() -> {
-                assert !currentThread().getName().toUpperCase().contains("EVENTLOOP") : currentThread().getName();
                 long beginEpchMs = currentTimeMillis();
                 List<KafkaProducerRecord<String, String>> kafkaProducerRecords = new ArrayList<>(recordsArray.size());
                 for (int i = 0; i < recordsArray.size(); i++) {