diff --git a/mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java b/mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java
index a506ffa81..a36a67242 100644
--- a/mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java
+++ b/mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java
@@ -102,7 +102,12 @@ public static List<ParameterDefinition<?>> parameters() {
                         .description(WriterProperties.WRITER_FILE_FORMAT_DESCRIPTION)
                         .validator(Validators.alwaysPass())
                         .defaultValue(WriterProperties.WRITER_FILE_FORMAT_DEFAULT)
-                        .build()
+                        .build(),
+                new IntParameter().name(WriterProperties.WRITER_MAXIMUM_POOL_SIZE)
+                    .description(WriterProperties.WRITER_MAXIMUM_POOL_SIZE_DESCRIPTION)
+                    .validator(Validators.alwaysPass())
+                    .defaultValue(WriterProperties.WRITER_MAXIMUM_POOL_SIZE_DEFAULT)
+                    .build()
         );
     }