diff --git a/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java b/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java index 59e14006..ad963e2e 100644 --- a/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java +++ b/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java @@ -139,7 +139,8 @@ private boolean recordSent(ChangeEvent record) { try { client.putRecord(putRecord); sent = true; - } catch (SdkClientException exception) { + } + catch (SdkClientException exception) { LOGGER.error("Failed to send record to {}:", record.destination(), exception); } return sent;