File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1126,10 +1126,10 @@ def verify_avro_explicit_read_schema():
11261126 msgcount += 1
11271127 # Avro schema projection should return the two fields not present in the writer schema
11281128 try :
1129- assert (msg .key ().get ('favorite_number' ) == 42 )
1130- assert (msg .key ().get ('favorite_color' ) == "purple" )
1131- assert (msg .value ().get ('favorite_number' ) == 42 )
1132- assert (msg .value ().get ('favorite_color' ) == "purple" )
1129+ assert (msg .key ().get ('favorite_number' ) == 42 )
1130+ assert (msg .key ().get ('favorite_color' ) == "purple" )
1131+ assert (msg .value ().get ('favorite_number' ) == 42 )
1132+ assert (msg .value ().get ('favorite_color' ) == "purple" )
11331133 print ("success: schema projection worked for explicit reader schema" )
11341134 except KeyError :
11351135 raise confluent_kafka .avro .SerializerError ("Schema projection failed when setting reader schema." )
You can’t perform that action at this time.
0 commit comments