in src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/DigitalSignatureService.java [65:79]
public <O> boolean isSealValid(String key, O input) {
if (!isEnabled) {
return true;
}
if (key == null) {
throw new ExternalCommunicationException(
"Required kafka header is missing",
new MessageHandlingException(new GenericMessage<>("Required kafka header is missing")),
Status.INTERNAL_CONTRACT_VIOLATION);
}
String signature = getSignature(key);
return verify(key, signature, serialize(input));
}