Skip to content

Commit 43a499d

Browse files
performance improvement
1 parent 027e77b commit 43a499d

File tree

1 file changed

+1
-11
lines changed

1 file changed

+1
-11
lines changed

superstream-clients/src/main/java/ai/superstream/core/ClientReporter.java

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -88,22 +88,12 @@ public boolean reportClient(String bootstrapServers, Properties originalClientPr
8888

8989
// Send the message
9090
ProducerRecord<String, String> record = new ProducerRecord<>(CLIENTS_TOPIC, json);
91-
producer.send(record).get(10, TimeUnit.SECONDS);
91+
producer.send(record);
9292
producer.flush();
9393
producer.close();
9494

9595
logger.debug("Successfully reported client information to {}", CLIENTS_TOPIC);
9696
return true;
97-
} catch (InterruptedException e) {
98-
Thread.currentThread().interrupt();
99-
logger.error("[ERR-023] Interrupted while reporting client information", e);
100-
return false;
101-
} catch (ExecutionException e) {
102-
logger.error("[ERR-024] Failed to report client information", e);
103-
return false;
104-
} catch (TimeoutException e) {
105-
logger.error("[ERR-025] Timed out while reporting client information", e);
106-
return false;
10797
} catch (Exception e) {
10898
logger.error("[ERR-026] Error reporting client information", e);
10999
return false;

0 commit comments

Comments
 (0)