Update tests to use decode_bootstrap_servers

lyoung-confluent · web-flow · commit f00d2c6f4c7f · 2022-09-05T15:39:35.000+02:00
diff --git a/tests/functional/test_data_classes.py b/tests/functional/test_data_classes.py
@@ -1147,7 +1147,7 @@ def test_kafka_event():
         "b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",
         "b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",
     ]
-    assert event.bootstrap_servers == bootstrap_servers
+    assert event.decoded_bootstrap_servers == bootstrap_servers
 
     records = list(event.records)
     assert len(records) == 1

Original file line number	Diff line number	Diff line change
`@@ -1147,7 +1147,7 @@ def test_kafka_event():`
`1147`	`1147`	`"b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",`
`1148`	`1148`	`"b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",`
`1149`	`1149`	`]`
`1150`		`- assert event.bootstrap_servers == bootstrap_servers`
	`1150`	`+ assert event.decoded_bootstrap_servers == bootstrap_servers`
`1151`	`1151`
`1152`	`1152`	`records = list(event.records)`
`1153`	`1153`	`assert len(records) == 1`