diff --git a/backend/pkg/connector/guide/mongo_source.go b/backend/pkg/connector/guide/mongo_source.go
index ff69ff90a..b25e94d20 100644
--- a/backend/pkg/connector/guide/mongo_source.go
+++ b/backend/pkg/connector/guide/mongo_source.go
@@ -76,6 +76,9 @@ func NewMongoSourceGuide(opts ...Option) Guide {
 							"heartbeat.interval.ms",
 							"heartbeat.topic.name",
 							"offset.partition.name",
+							"topic.creation.enable",
+							"topic.creation.default.partitions",
+							"topic.creation.default.replication.factor",
 						},
 					},
 				},
diff --git a/backend/pkg/connector/interceptor/interceptor.go b/backend/pkg/connector/interceptor/interceptor.go
index 2a20cfb4c..d3dd5416d 100644
--- a/backend/pkg/connector/interceptor/interceptor.go
+++ b/backend/pkg/connector/interceptor/interceptor.go
@@ -100,6 +100,7 @@ func CommunityGuides(opts ...guide.Option) []guide.Guide {
 		guide.NewMongoSourceGuide(guide.WithConsoleToKafkaConnectHookFn(ConsoleToKafkaConnectMongoDBHook),
 			guide.WithKafkaConnectValidateToConsoleHookFn(KafkaConnectValidateToConsoleMongoDBHook),
 			guide.WithKafkaConnectValidateToConsoleHookFn(KafkaConnectToConsoleJSONSchemaHook),
+			guide.WithKafkaConnectValidateToConsoleHookFn(KafkaConnectToConsoleTopicCreationHook),
 			guide.WithKafkaConnectToConsoleHookFn(KafkaConnectToConsoleMongoDBHook)),
 		guide.NewMongoSinkGuide(guide.WithConsoleToKafkaConnectHookFn(ConsoleToKafkaConnectMongoDBHook),
 			guide.WithKafkaConnectValidateToConsoleHookFn(KafkaConnectValidateToConsoleMongoDBHook),