Skip to content

Commit 6d37671

Browse files
committed
Remove line used for debugging
Signed-off-by: Jeffrey Aaron Jeyasingh <jeffreyaaron06@gmail.com>
1 parent b656122 commit 6d37671

1 file changed

Lines changed: 2 additions & 7 deletions

File tree

  • data-prepper-plugins/kafka-plugins/src/integrationTest/java/org/opensearch/dataprepper/plugins/kafka/buffer

data-prepper-plugins/kafka-plugins/src/integrationTest/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferIT.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -56,14 +56,10 @@
5656
import static org.awaitility.Awaitility.await;
5757
import static org.hamcrest.CoreMatchers.not;
5858
import static org.hamcrest.MatcherAssert.assertThat;
59-
import static org.hamcrest.Matchers.equalTo;
60-
import static org.hamcrest.Matchers.hasKey;
61-
import static org.hamcrest.Matchers.notNullValue;
59+
import static org.hamcrest.Matchers.*;
6260
import static org.junit.jupiter.api.Assertions.assertThrows;
6361
import static org.mockito.ArgumentMatchers.any;
64-
import static org.mockito.Mockito.lenient;
65-
import static org.mockito.Mockito.mock;
66-
import static org.mockito.Mockito.when;
62+
import static org.mockito.Mockito.*;
6763
import static org.opensearch.dataprepper.plugins.kafka.buffer.ReadBufferHelper.awaitRead;
6864
import static org.opensearch.dataprepper.test.helper.ReflectivelySetField.setField;
6965

@@ -121,7 +117,6 @@ void setUp() {
121117
);
122118

123119
bootstrapServersCommaDelimited = System.getProperty("tests.kafka.bootstrap_servers");
124-
bootstrapServersCommaDelimited = "localhost:9092";
125120

126121
LOG.info("Using Kafka bootstrap servers: {}", bootstrapServersCommaDelimited);
127122

0 commit comments

Comments
 (0)