File tree Expand file tree Collapse file tree 3 files changed +10
-13
lines changed
Expand file tree Collapse file tree 3 files changed +10
-13
lines changed Original file line number Diff line number Diff line change 1- from avro .schema import SchemaFromJSONData
2-
3- from schema_registry .client import SchemaRegistryClient
1+ from schema_registry .client import SchemaRegistryClient , schema
42from schema_registry .serializers import FaustSerializer
53
64from simple_settings import settings
97# Initialize Schema Registry Client
108client = SchemaRegistryClient (url = settings .SCHEMA_REGISTRY_URL )
119
12- avro_user_schema = SchemaFromJSONData ({
10+ avro_user_schema = schema . AvroSchema ({
1311 "type" : "record" ,
1412 "namespace" : "com.example" ,
1513 "name" : "AvroUsers" ,
Original file line number Diff line number Diff line change 11from setuptools import setup , find_packages
22
33requires = [
4- "avro-python3" ,
5- "colorlog==3.1.4" ,
6- "fastavro" ,
7- "robinhood-aiokafka==1.0.3" ,
8- "requests==2.22.0" ,
9- "simple-settings==0.16.0" ,
10- "python-schema-registry-client[faust]==0.3.0" ,
4+ "colorlog>=3.1.4" ,
5+ "fastavro>=0.22.3" ,
6+ "robinhood-aiokafka>=1.0.3" ,
7+ "requests>=2.22.0" ,
8+ "simple-settings>=0.16.0" ,
9+ "python-schema-registry-client[faust]>=1.0.0" ,
1110]
1211
1312setup (
1413 name = 'faust-example' ,
15- version = '1.1.3 ' ,
14+ version = '1.1.4 ' ,
1615 description = 'Faust example with Docker Compose' ,
1716 long_description = '''
1817 Example running Faust with Docker Compose (zookeeper, kafka and schema-registry)
Original file line number Diff line number Diff line change 1- faust==1.5.4
1+ faust==1.7.0
22simple-settings==0.16.0
33
44# Testing
You can’t perform that action at this time.
0 commit comments