Skip to content

Commit

Permalink
fix: Dependencies updated.
Browse files Browse the repository at this point in the history
  • Loading branch information
marcosschroh committed Jun 11, 2019
1 parent 0876ef3 commit ea2316d
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 41 deletions.
1 change: 1 addition & 0 deletions faust-project/example/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,3 +15,4 @@

def main() -> None:
app.main()

9 changes: 2 additions & 7 deletions faust-project/example/codecs/avro.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
from avro.schema import SchemaFromJSONData

from schema_registry.client import SchemaRegistryClient
from schema_registry.serializers import FaustSerializer

from simple_settings import settings

from .serializers import AvroSerializer


# Initialize Schema Registry Client
client = SchemaRegistryClient(url=settings.SCHEMA_REGISTRY_URL)
Expand All @@ -20,11 +19,7 @@
]
})

avro_user_serializer = AvroSerializer(
schema_registry_client=client,
destination_topic="users",
schema=avro_user_schema
)
avro_user_serializer = FaustSerializer(client, "users", avro_user_schema)


def avro_user_codec():
Expand Down
30 changes: 0 additions & 30 deletions faust-project/example/codecs/serializers.py

This file was deleted.

7 changes: 3 additions & 4 deletions faust-project/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,15 @@
"avro-python3",
"colorlog==3.1.4",
"fastavro",
"faust==1.5.4",
"robinhood-aiokafka==1.0.2",
"robinhood-aiokafka==1.0.3",
"requests==2.22.0",
"simple-settings==0.16.0",
"python-schema-registry-client==0.2.4",
"python-schema-registry-client[faust]==0.3.0",
]

setup(
name='faust-example',
version='1.1.1',
version='1.1.2',
description='Faust example with Docker Compose',
long_description='''
Example running Faust with Docker Compose (zookeeper, kafka and schema-registry)
Expand Down

0 comments on commit ea2316d

Please sign in to comment.