Enum Classes In Kafka

[JeffreyHuynh1]

Description

• Situation:
  • The avro classes with enum types cause an error when serializing and deserializing to json
    • This causes errors when going back and forth from python dictionary to avro classes ( want this capability to use the avro classes for validation )
  • We can turn the avro types of that field to a string type, but then we lose the validation aspect
• Result:
  • In order to use the avro enum classes, we have to manually create an instance of the enum type on serialization/ deserialization
  • More work and time consuming

Tasks

• Find the best way to incorporate these avro enum classes
  • pyavro-gen generation classes may be an option?

[JeffreyHuynh1]

Created a json encoder class to hand serialization/deserialization for the avro enum classes