File tree 1 file changed +4
-4
lines changed
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():
1126
1126
msgcount += 1
1127
1127
# Avro schema projection should return the two fields not present in the writer schema
1128
1128
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" )
1133
1133
print ("success: schema projection worked for explicit reader schema" )
1134
1134
except KeyError :
1135
1135
raise confluent_kafka .avro .SerializerError ("Schema projection failed when setting reader schema." )
You can’t perform that action at this time.
0 commit comments