File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
managedkafka/managedkafka_create_connector_mirrormaker2_source Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -106,8 +106,8 @@ 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.bootstrap_servers
110- " target.cluster.bootstrap.servers" = google_managed_kafka_cluster.target.bootstrap_servers
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
111111 # Using a replication policy is a good practice to identify mirrored topics.
112112 # It prefixes the topic name with the source alias (e.g., "source.my-topic").
113113 " replication.policy.class" = " org.apache.kafka.connect.mirror.DefaultReplicationPolicy"
You can’t perform that action at this time.
0 commit comments