🔥refactor: remove unit test of Kafka and add db close()

Author: sasaxie

src/test/java/org/tron/core/BlockchainTest.java

@@ -139,5 +139,6 @@ public void testAddBlockToChain() {
         levelDbDataSource.putData(key, values);
 
         blockchain.addBlock(block);
+        levelDbDataSource.closeDB();
     }
 }

src/test/java/org/tron/overlay/kafka/KafkaTest.java

@@ -32,29 +32,29 @@ public class KafkaTest {
 
     @Test
     public void testKafka() {
-        ReceiveSource source = new ReceiveSource();
-        source.addReceiveListener((Message message) -> {
-            if (message.getType() == Type.BLOCK) {
-                System.out.println(message.getMessage());
-            }
-        });
-
-        source.addReceiveListener((Message message) -> {
-            if (message.getType() == Type.TRANSACTION) {
-                System.out.println(message.getMessage());
-            }
-        });
-
-        Net net = new Kafka(source, Arrays.asList(TOPIC_BLOCK, TOPIC_TRANSACTION));
-
-        net.broadcast(new Message("hello block", Type.BLOCK));
-        net.broadcast(new Message("hello transaction", Type.TRANSACTION));
-
-        long startTime = System.currentTimeMillis();
-        long endTime = System.currentTimeMillis();
-
-        while (endTime - startTime < 50000) {
-            endTime = System.currentTimeMillis();
-        }
+//        ReceiveSource source = new ReceiveSource();
+//        source.addReceiveListener((Message message) -> {
+//            if (message.getType() == Type.BLOCK) {
+//                System.out.println(message.getMessage());
+//            }
+//        });
+//
+//        source.addReceiveListener((Message message) -> {
+//            if (message.getType() == Type.TRANSACTION) {
+//                System.out.println(message.getMessage());
+//            }
+//        });
+//
+//        Net net = new Kafka(source, Arrays.asList(TOPIC_BLOCK, TOPIC_TRANSACTION));
+//
+//        net.broadcast(new Message("hello block", Type.BLOCK));
+//        net.broadcast(new Message("hello transaction", Type.TRANSACTION));
+//
+//        long startTime = System.currentTimeMillis();
+//        long endTime = System.currentTimeMillis();
+//
+//        while (endTime - startTime < 50000) {
+//            endTime = System.currentTimeMillis();
+//        }
     }
 }