@@ -113,7 +113,7 @@ func resourceCockroachDBChangefeedCreate(db *DBConnection, d *schema.ResourceDat
113
113
}
114
114
115
115
d .SetId (jobID )
116
- d .Set (CDCAvroSchemaPrefix , fmt . Sprintf ( "%s" , avroSchemaPrefix ) )
116
+ d .Set (CDCAvroSchemaPrefix , avroSchemaPrefix )
117
117
d .Set (CDCRegistryConnectionName , registryConnectionName )
118
118
d .Set (CDCKafkaConnectionName , kafkaConnectionName )
119
119
d .Set (CDCtableList , tableList )
@@ -151,7 +151,7 @@ func resourceCockroachDBChangefeedReadImpl(db *DBConnection, d *schema.ResourceD
151
151
d .Set (CDCKafkaConnectionName , strings .TrimPrefix (sinkUri , "external://" ))
152
152
// setting the avro schema prefix and confluent schema registry
153
153
avroSchemaPrefix , confluentSchemaRegistry , initialScanValue , cursorValue := extractDetails (description )
154
- d .Set (CDCAvroSchemaPrefix , fmt . Sprintf ( "%s" , strings .TrimSuffix (avroSchemaPrefix , "_" ) ))
154
+ d .Set (CDCAvroSchemaPrefix , strings .TrimSuffix (avroSchemaPrefix , "_" ))
155
155
d .Set (CDCRegistryConnectionName , confluentSchemaRegistry )
156
156
if initialScanValue == "yes" {
157
157
d .Set (CDCInitialScan , "yes" )
0 commit comments