File tree Expand file tree Collapse file tree 5 files changed +16
-12
lines changed
Expand file tree Collapse file tree 5 files changed +16
-12
lines changed Original file line number Diff line number Diff line change @@ -23,12 +23,15 @@ remove:
2323 # Try this if this fails: docker rm -f $(docker ps -a -q)
2424 docker-compose rm --force -v
2525
26+ remove-network :
27+ docker network rm faust-docker-compose_default
28+
2629stop :
2730 docker-compose stop
2831
2932run-dev : build run
3033
31- clean : stop remove
34+ clean : stop remove remove-network
3235
3336# Kafka related
3437create-topic :
Original file line number Diff line number Diff line change 11FROM python:3.7-slim
2-
3- RUN echo 'deb http://http .debian.net /debian jessie-backports main' >> /etc/apt/sources.list \
2+
3+ RUN echo 'deb [check-valid-until=no] http://archive .debian.org /debian jessie-backports main' >> /etc/apt/sources.list \
44 && apt-get update \
55 && apt-get install -y --no-install-recommends apt-utils
66
Original file line number Diff line number Diff line change 2121})
2222
2323avro_user_serializer = AvroSerializer (
24- schema_registry_client = client ,
25- destination_topic = "users" ,
26- schema = avro_user_schema )
24+ schema_registry_client = client ,
25+ destination_topic = "users" ,
26+ schema = avro_user_schema
27+ )
2728
2829
2930def avro_user_codec ():
Original file line number Diff line number Diff line change @@ -23,8 +23,8 @@ def _loads(self, s: bytes) -> Dict:
2323
2424 def _dumps (self , obj : Dict ) -> bytes :
2525 return self .encode_record_with_schema (
26- topic = self .destination_topic ,
27- schema = self .schema ,
28- record = obj ,
26+ self .destination_topic ,
27+ self .schema ,
28+ obj ,
2929 is_key = self .is_key
30- )
30+ )
Original file line number Diff line number Diff line change 66 "fastavro" ,
77 "faust==1.5.4" ,
88 "robinhood-aiokafka==1.0.2" ,
9- "requests" ,
9+ "requests==2.22.0 " ,
1010 "simple-settings==0.16.0" ,
11- "python-schema-registry-client==0.0.2 " ,
11+ "python-schema-registry-client==0.2.4 " ,
1212]
1313
1414setup (
You can’t perform that action at this time.
0 commit comments