v0.26.0

Author: osheroff

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Changelog
 
+## [0.26.0](https://github.com/osheroff/mysql-binlog-connector-java/compare/0.25.6...0.26.0) - 2022-07-15
+
+- Compressed binlogs, thank you Somesh Malviya
+- fix crash on unknown field type
+
+# Changelog
+
 ## [0.25.6](https://github.com/osheroff/mysql-binlog-connector-java/compare/0.25.5...0.25.6) - 2022-04-14
 
 - stop crashing in an inopportune place

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java

@@ -780,6 +780,7 @@ public void run() {
                             // expected in case of disconnect
                         }
                         if (threadExecutor.isShutdown()) {
+                            logger.info("threadExecutor is shut down, terminating keepalive thread");
                             return;
                         }
                         boolean connectionLost = false;

src/main/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStream.java

@@ -60,7 +60,7 @@ public int read(byte[] b, int off, int len) throws IOException {
             }
             offset = 0;
             limit = in.read(buffer, 0, buffer.length);
-            
+
             if (limit == -1) {
                 return -1;
             }

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java

@@ -178,4 +178,15 @@ public void run() {
         }
     }
 
+    @Test
+    public void testDeadlockyCode() throws IOException, InterruptedException {
+        final BinaryLogClient binaryLogClient = new BinaryLogClient("localhost", 3306, "root", "123456");
+        binaryLogClient.setHeartbeatInterval(10000);
+        binaryLogClient.setKeepAlive(true);
+        binaryLogClient.setKeepAliveInterval(2000);
+
+        binaryLogClient.connect();
+
+        Thread.sleep(10000000);
+    }
 }