diff --git a/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java b/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java index 0f0e8fc64d..8a02f203e5 100644 --- a/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java +++ b/src/main/java/org/zalando/nakadi/service/subscription/state/StreamingState.java @@ -337,7 +337,7 @@ private void flushData(final EventTypePartition pk, final List da batchesSent++; } catch (final IOException e) { - getLog().error("Failed to write data to output.", e); + getLog().warn("Failed to write data to output: {}", e.getMessage()); shutdownGracefully("Failed to write data to output"); } }