Skip to content

Commit

Permalink
revert avro_producer changes
Browse files Browse the repository at this point in the history
  • Loading branch information
EladLeev committed Apr 6, 2023
1 parent 29259d8 commit 0df01ef
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions scripts/avro_producer.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,7 @@
"fields": [
{"name": "id", "type": "string"},
{"name": "amount", "type": "double"},
{"name": "name", "type": "string"},
{"name": "asd", "type": "string", "default": ""},
{"name": "asd2", "type": "string", "default": ""}
{"name": "name", "type": "string"}
]
}
"""
Expand All @@ -40,7 +38,5 @@
avroProducer.produce(topic='payments-topic',
value={"id": "transact_%s" % i,
"amount": random.uniform(10, 500),
"name": "customer_%s" % i,
"asd": "asdasdasdasd",
"asd2": "asdasdasdasd",})
"name": "customer_%s" % i, })
avroProducer.flush()

0 comments on commit 0df01ef

Please sign in to comment.