[Feature][Connector-V2] Make some sink parameters optional for DataHub (#9229)

Author: jia17

docs/en/connector-v2/sink/Datahub.md

@@ -21,8 +21,8 @@ A sink plugin which use send message to DataHub
 | accessKey      | string | yes      | -             |
 | project        | string | yes      | -             |
 | topic          | string | yes      | -             |
-| timeout        | int    | yes      | -             |
-| retryTimes     | int    | yes      | -             |
+| timeout        | int    | no       | 3000          |
+| retryTimes     | int    | no       | 3             |
 | common-options |        | no       | -             |
 
 ### endpoint [string]

docs/zh/connector-v2/sink/Datahub.md

@@ -14,16 +14,16 @@ import ChangeLog from '../changelog/connector-datahub.md';
 
 ## 选项
 
-|      名称           |  类型  | 必需 | 默认值 |
-|----------------|--------|----|---------------|
-| endpoint       | string | 是  | -             |
-| accessId       | string | 是  | -             |
-| accessKey      | string | 是  | -             |
-| project        | string | 是  | -             |
-| topic          | string | 是  | -             |
-| timeout        | int    | 是  | -             |
-| retryTimes     | int    | 是  | -             |
-| common-options |        | 否  | -             |
+|      名称           |  类型  | 必需  | 默认值  |
+|----------------|--------|-----|------|
+| endpoint       | string | 是   | -    |
+| accessId       | string | 是   | -    |
+| accessKey      | string | 是   | -    |
+| project        | string | 是   | -    |
+| topic          | string | 是   | -    |
+| timeout        | int    | 否   | 3000 |
+| retryTimes     | int    | 否   | 3    |
+| common-options |        | 否   | -    |
 
 ### endpoint [string]
 

seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/config/DataHubSinkOptions.java

@@ -57,12 +57,12 @@ public class DataHubSinkOptions {
     public static Option<Integer> TIMEOUT =
             Options.key("timeout")
                     .intType()
-                    .noDefaultValue()
+                    .defaultValue(3000)
                     .withDescription("The max connection timeout");
 
     public static Option<Integer> RETRY_TIMES =
             Options.key("retryTimes")
                     .intType()
-                    .noDefaultValue()
+                    .defaultValue(3)
                     .withDescription("The max retry times when your client put record failed");
 }

seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSinkFactory.java

@@ -44,8 +44,9 @@ public String factoryIdentifier() {
     @Override
     public OptionRule optionRule() {
         return OptionRule.builder()
-                .required(ENDPOINT, ACCESS_ID, ACCESS_KEY, PROJECT, TOPIC, TIMEOUT, RETRY_TIMES)
+                .required(ENDPOINT, ACCESS_ID, ACCESS_KEY, PROJECT, TOPIC)
                 .optional(SinkConnectorCommonOptions.MULTI_TABLE_SINK_REPLICA)
+                .optional(TIMEOUT, RETRY_TIMES)
                 .build();
     }