diff --git a/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java b/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java index 8a9ce47..fb6b823 100644 --- a/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java +++ b/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java @@ -119,7 +119,7 @@ private void sendACK(Channel channel) throws IOException { buffer.writeInt((int) sequenceNum); LOG.trace("Sending ACK for sequence number {} on channel {}", sequenceNum, channel); - channel.write(buffer).awaitUninterruptibly(); + channel.write(buffer); } }