resolve comments

microsoft · Sep 27, 2022 · 5467801 · 5467801
1 parent b67c36a
commit 5467801
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/azure/cosmos/kafka/connect/CosmosDBConfig.java b/src/main/java/com/azure/cosmos/kafka/connect/CosmosDBConfig.java
@@ -145,14 +145,14 @@ private static void defineConnectionConfigs(ConfigDef result) {
                         COSMOS_SINK_BULK_ENABLED_CONF,
                         Type.BOOLEAN,
                         DEFAULT_COSMOS_SINK_BULK_ENABLED,
-                        Importance.MEDIUM,
+                        Importance.LOW,
                         COSMOS_SINK_BULK_ENABLED_DOC
                 )
                 .define(
                         COSMOS_SINK_MAX_RETRY_COUNT,
                         Type.INT,
                         DEFAULT_COSMOS_SINK_MAX_RETRY_COUNT,
-                        Importance.MEDIUM,
+                        Importance.HIGH,
                         COSMOS_SINK_MAX_RETRY_COUNT_DOC
                 )
                 .defineInternal(

diff --git a/src/main/java/com/azure/cosmos/kafka/connect/sink/BulkWriter.java b/src/main/java/com/azure/cosmos/kafka/connect/sink/BulkWriter.java
@@ -68,7 +68,7 @@ protected SinkWriteResponse writeCore(List<SinkRecord> sinkRecords) {
         Iterable<CosmosBulkOperationResponse<Object>> responseList = cosmosContainer.executeBulkOperations(itemOperations);
 
         // Non-transient exceptions will be put in the front of the list
-        for (CosmosBulkOperationResponse bulkOperationResponse : responseList) {
+        for (CosmosBulkOperationResponse<Object> bulkOperationResponse : responseList) {
             SinkOperationContext context = bulkOperationResponse.getOperation().getContext();
             checkNotNull(context, "sinkOperationContext should not be null");