From 5bda148d2b0c30db9a156459baf825381bdf2d72 Mon Sep 17 00:00:00 2001 From: Andreas Fankhauser <23085769+hiddenalpha@users.noreply.github.com> Date: Thu, 6 Jun 2024 10:39:07 +0200 Subject: [PATCH] [SDCISA-16147, #583] Allow threading bugs to slip through. Related: SDCISA-15633, SDCISA-15833, SDCISA-16147, https://github.com/swisspost/vertx-redisques/issues/170, https://github.com/swisspost/vertx-redisques/pull/177, https://github.com/swisspost/vertx-rest-storage/pull/186, #577, https://github.com/swisspost/vertx-redisques/pull/181, #493, https://github.com/swisspost/vertx-rest-storage/issues/188, #583 --- .../org/swisspush/gateleen/kafka/KafkaProducerRecordBuilder.java | 1 - 1 file changed, 1 deletion(-) 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>> 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> kafkaProducerRecords = new ArrayList<>(recordsArray.size()); for (int i = 0; i < recordsArray.size(); i++) {