Skip to content

Commit 080f2b0

Browse files
committed
Fix bootstrap server addresses and add comment.
1 parent 7970c79 commit 080f2b0

File tree

1 file changed

+4
-2
lines changed
  • managedkafka/managedkafka_create_connector_mirrormaker2_source

1 file changed

+4
-2
lines changed

managedkafka/managedkafka_create_connector_mirrormaker2_source/main.tf

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,8 +106,10 @@ resource "google_managed_kafka_connector" "default" {
106106
"source.cluster.alias" = "source"
107107
"target.cluster.alias" = "target"
108108
"topics" = ".*" # Replicate all topics from the source
109-
"source.cluster.bootstrap.servers" = google_managed_kafka_cluster.source.gcp_config[0].access_config[0].network_configs[0].bootstrap_servers
110-
"target.cluster.bootstrap.servers" = google_managed_kafka_cluster.target.gcp_config[0].access_config[0].network_configs[0].bootstrap_servers
109+
# The value for bootstrap.servers is a comma-separated list of hostname:port pairs for one
110+
# or more Kafka brokers in the source/target cluster.
111+
"source.cluster.bootstrap.servers" = "source_cluster_dns"
112+
"target.cluster.bootstrap.servers" = "target_cluster_dns"
111113
# Using a replication policy is a good practice to identify mirrored topics.
112114
# It prefixes the topic name with the source alias (e.g., "source.my-topic").
113115
"replication.policy.class" = "org.apache.kafka.connect.mirror.DefaultReplicationPolicy"

0 commit comments

Comments
 (0)