in src/main/java/software/amazon/event/kafkaconnector/exceptions/EventBridgePartialFailureResponse.java [11:20]
public EventBridgePartialFailureResponse(SinkRecord sinkRecord, String message, Throwable cause) {
super(
String.format(
"errorMessage=%s topic=%s partition=%d offset=%d cause=%s",
message,
sinkRecord.topic(),
sinkRecord.kafkaPartition(),
sinkRecord.kafkaOffset(),
cause));
}