SR integration tests relied on SR at :8081 despite Trivup fixture

Author: edenhill

tests/integration/schema_registry/test_json_serializers.py

@@ -91,7 +91,7 @@ def test_json_record_serialization(kafka_cluster, load_file):
 
     """
     topic = kafka_cluster.create_topic("serialization-json")
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
 
     schema_str = load_file("product.json")
     value_serializer = JSONSerializer(schema_str, sr)
@@ -139,7 +139,7 @@ def test_json_record_serialization_incompatible(kafka_cluster, load_file):
 
     """
     topic = kafka_cluster.create_topic("serialization-json")
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
 
     schema_str = load_file("product.json")
     value_serializer = JSONSerializer(schema_str, sr)
@@ -165,7 +165,7 @@ def test_json_record_serialization_no_title(kafka_cluster, load_file):
         load_file (callable(str)): JSON Schema file reader
 
     """
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
     schema_str = load_file('not_title.json')
 
     with pytest.raises(ValueError,
@@ -184,7 +184,7 @@ def test_json_record_serialization_custom(kafka_cluster, load_file):
 
     """
     topic = kafka_cluster.create_topic("serialization-json")
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
 
     schema_str = load_file("product.json")
     value_serializer = JSONSerializer(schema_str, sr,
@@ -228,7 +228,7 @@ def test_json_record_deserialization_mismatch(kafka_cluster, load_file):
 
     """
     topic = kafka_cluster.create_topic("serialization-json")
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
 
     schema_str = load_file("contractor.json")
     schema_str2 = load_file("product.json")

tests/integration/schema_registry/test_proto_serializers.py

@@ -54,7 +54,7 @@ def test_protobuf_message_serialization(kafka_cluster, pb2, data):
 
     """
     topic = kafka_cluster.create_topic("serialization-proto")
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
 
     value_serializer = ProtobufSerializer(pb2, sr)
     value_deserializer = ProtobufDeserializer(pb2)
@@ -85,7 +85,7 @@ def test_protobuf_reference_registration(kafka_cluster, pb2, expected_refs):
     Registry to ensure the references match up.
 
     """
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
     topic = kafka_cluster.create_topic("serialization-proto-refs")
     serializer = ProtobufSerializer(pb2, sr)
     producer = kafka_cluster.producer(key_serializer=serializer)
@@ -106,7 +106,7 @@ def test_protobuf_serializer_type_mismatch(kafka_cluster):
     pb2_1 = TestProto_pb2.TestMessage
     pb2_2 = NestedTestProto_pb2.NestedMessage
 
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
     topic = kafka_cluster.create_topic("serialization-proto-refs")
     serializer = ProtobufSerializer(pb2_1, sr)
 
@@ -127,7 +127,7 @@ def test_protobuf_deserializer_type_mismatch(kafka_cluster):
     pb2_1 = PublicTestProto_pb2.TestMessage
     pb2_2 = metadata_proto_pb2.HDFSOptions
 
-    sr = kafka_cluster.schema_registry({'url': 'http://localhost:8081'})
+    sr = kafka_cluster.schema_registry()
     topic = kafka_cluster.create_topic("serialization-proto-refs")
     serializer = ProtobufSerializer(pb2_1, sr)
     deserializer = ProtobufDeserializer(pb2_2)