Skip to content

Commit

Permalink
chore(kafka): improve kafka execution error message (#2047)
Browse files Browse the repository at this point in the history
Oleksiivanov authored Feb 29, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
1 parent aa76969 commit 153a721
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -103,7 +103,10 @@ private KafkaConnectorResponse executeConnector(final KafkaConnectorRequest requ
Future<RecordMetadata> kafkaResponse = producer.send(producerRecord);
return constructKafkaConnectorResponse(kafkaResponse.get(45, TimeUnit.SECONDS));
} catch (Exception e) {
throw new ConnectorException("FAIL", "Kafka Producer execution exception", e);
throw new ConnectorException(
"FAIL",
"Error during Kafka Producer execution; error message: [" + e.getMessage() + "]",
e);
}
}

0 comments on commit 153a721

Please sign in to comment.