make RNG static and not new Random()...

Signed-off-by: see-quick <[email protected]>

Author: see-quick

src/test/java/io/strimzi/kafka/bridge/http/SeekIT.java

@@ -434,15 +434,6 @@ void seekToBeginningMultipleTopicsWithNotSubscribedTopic(VertxTestContext contex
                 .createConsumer(context, groupId, jsonConsumer)
                 .subscribeConsumer(context, groupId, name, topics);
 
-        CompletableFuture<Boolean> consume = new CompletableFuture<>();
-
-        // poll to subscribe
-        consumerService()
-            .consumeRecordsRequest(groupId, name, BridgeContentType.KAFKA_JSON_JSON)
-            .as(BodyCodec.jsonObject())
-            .send()
-            .onComplete(ar -> consume.complete(true));
-
         waitUntilPartitionAssigned(consumerService(), groupId, name, 5, 200);
 
         // seek

src/test/java/io/strimzi/kafka/bridge/http/base/HttpBridgeITAbstract.java

@@ -102,6 +102,8 @@ public abstract class HttpBridgeITAbstract implements TestSeparator {
     protected static HttpBridge httpBridge;
     protected static BridgeConfig bridgeConfig;
 
+    private final static Random RNG = new Random();
+
     @BeforeAll
     void beforeAll(VertxTestContext context) {
         LOGGER.info("Environment variable EXTERNAL_BRIDGE:" + BRIDGE_EXTERNAL_ENV);
@@ -130,7 +132,7 @@ static void afterAll(VertxTestContext context) {
 
     @BeforeEach
     void setUpEach() {
-        topic = "my-topic-" + new Random().nextInt(Integer.MAX_VALUE);
+        topic = "my-topic-" + RNG.nextInt(Integer.MAX_VALUE);
     }
 
     @AfterEach
@@ -157,7 +159,7 @@ void cleanUp() throws InterruptedException, ExecutionException {
     }
 
     protected String generateRandomConsumerGroupName() {
-        int salt = new Random().nextInt(Integer.MAX_VALUE);
+        int salt = RNG.nextInt(Integer.MAX_VALUE);
         return "my-group-" + salt;
     }