docs: markdown format

docs/en/14-reference/03-connector/04-java.mdx

@@ -425,7 +425,7 @@ while(resultSet.next()){
 
 This reqId can be used to request link tracing.
 
-```
+```java
 AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
 aStmt.execute("create database if not exists db", 1L);
 aStmt.executeUpdate("use db", 2L);
@@ -955,7 +955,7 @@ public class SchemalessWsTest {
 
 This reqId can be used to request link tracing.
 
-```
+```java
 writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
 ```
 
@@ -1016,7 +1016,7 @@ while(true) {
 
 #### Assignment subscription Offset
 
-```
+```java
 long position(TopicPartition partition) throws SQLException;
 Map<TopicPartition, Long> position(String topic) throws SQLException;
 Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
@@ -1027,7 +1027,7 @@ void seek(TopicPartition partition, long offset) throws SQLException;
 
 Example usage is as follows.
 
-```
+```java
 String topic = "offset_seek_test";
 Map<TopicPartition, Long> offset = null;
 try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {

docs/zh/08-connector/14-java.mdx

@@ -428,7 +428,7 @@ while(resultSet.next()){
 
 此 reqId 可用于请求链路追踪。
 
-```
+```java
 AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
 aStmt.execute("create database if not exists db", 1L);
 aStmt.executeUpdate("use db", 2L);
@@ -958,7 +958,7 @@ public class SchemalessWsTest {
 
 此 reqId 可用于请求链路追踪。
 
-```
+```java
 writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
 ```
 
@@ -1019,7 +1019,7 @@ while(true) {
 
 #### 指定订阅 Offset
 
-```
+```java
 long position(TopicPartition partition) throws SQLException;
 Map<TopicPartition, Long> position(String topic) throws SQLException;
 Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
@@ -1030,7 +1030,7 @@ void seek(TopicPartition partition, long offset) throws SQLException;
 
 示例代码：
 
-```
+```java
 String topic = "offset_seek_test";
 Map<TopicPartition, Long> offset = null;
 try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {