wintoncode / winton-kafka-streams

A Python implementation of Apache Kafka Streams
Apache License 2.0
313 stars 55 forks source link

Add to wordcount example providing an option to use custom serialiser #44

Closed sambott closed 6 years ago

sambott commented 6 years ago

Addresses #43

This adds a --binary-output option to the wordcount example that uses a custom serializer.

The custom serializer writes binary integers to the output topic rather than the string representation of them.

There is also an improvement to the StringSerde that removes the necessity to pre-cast values to strings.