Merge pull request #1019 from redpanda-data/ts/add-topic-creation-to-…

…mongodb-source Add topic creation properties to MongodDB source connector guide
redpanda-data · Jan 22, 2024 · 7820bc2 · 7820bc2
2 parents 5db7f34 + d074099
commit 7820bc2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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),