From 6328b4310400b5e963913e95970b2d25a88b4a3a Mon Sep 17 00:00:00 2001
From: huolibo <huolibo@qq.com>
Date: Tue, 20 Jun 2023 18:03:27 +0800
Subject: [PATCH] docs: markdown format

---
 docs/en/14-reference/03-connector/04-java.mdx | 8 ++++----
 docs/zh/08-connector/14-java.mdx              | 8 ++++----
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/docs/en/14-reference/03-connector/04-java.mdx b/docs/en/14-reference/03-connector/04-java.mdx
index 9376850d3e..ebd2891a9e 100644
--- a/docs/en/14-reference/03-connector/04-java.mdx
+++ b/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)) {
diff --git a/docs/zh/08-connector/14-java.mdx b/docs/zh/08-connector/14-java.mdx
index 7b22055c62..27b732b883 100644
--- a/docs/zh/08-connector/14-java.mdx
+++ b/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)) {
-- 
GitLab