diff --git a/data-prepper-plugins/kafka-plugins/src/test/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferTest.java b/data-prepper-plugins/kafka-plugins/src/test/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferTest.java index 88803dcb57..37a9c6e8bf 100644 --- a/data-prepper-plugins/kafka-plugins/src/test/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferTest.java +++ b/data-prepper-plugins/kafka-plugins/src/test/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferTest.java @@ -231,6 +231,5 @@ void test_kafkaBuffer_getDrainTimeout() { assertThat(result, equalTo(duration)); verify(bufferConfig).getDrainTimeout(); - verify(kafkaBuffer).getDrainTimeout(); } } \ No newline at end of file