Skip to content

Commit 9e22a55

Browse files
authored
add logs in FailureTrackingAirbyteMessageConsumer for debug (#10455)
1 parent 833f79a commit 9e22a55

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/FailureTrackingAirbyteMessageConsumer.java

+2
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ public void start() throws Exception {
3636
AirbyteSentry.executeWithTracing("StartConsumer", this::startTracked,
3737
Map.of("consumerImpl", FailureTrackingAirbyteMessageConsumer.class.getSimpleName()));
3838
} catch (final Exception e) {
39+
LOGGER.error("Exception while starting consumer", e);
3940
hasFailed = true;
4041
throw e;
4142
}
@@ -48,6 +49,7 @@ public void accept(final AirbyteMessage msg) throws Exception {
4849
try {
4950
acceptTracked(msg);
5051
} catch (final Exception e) {
52+
LOGGER.error("Exception while accepting message", e);
5153
hasFailed = true;
5254
throw e;
5355
}

0 commit comments

Comments
 (0)