Skip to content

Commit

Permalink
add link to Confluent Wire definition
Browse files Browse the repository at this point in the history
  • Loading branch information
troyraen committed Jul 6, 2024
1 parent 331bbea commit 4003c67
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion pittgoogle/schema.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,9 +253,13 @@ def deserialize(self, alert_bytes: bytes) -> dict:


class _ConfluentWireAvroSchema(Schema):
"""Schema to serialize and deserialize alert bytes in the Avro Confluent Wire Format."""
"""Schema to serialize and deserialize alert bytes in the Avro Confluent Wire Format.
https://docs.confluent.io/platform/current/schema-registry/fundamentals/serdes-develop/index.html#wire-format
"""

def serialize(self, alert_dict: dict) -> bytes:
# [TODO]
raise NotImplementedError("Confluent Wire Format not yet supported.")

def deserialize(self, alert_bytes: bytes) -> dict:
Expand Down

0 comments on commit 4003c67

Please sign in to comment.