wintoncode / winton-kafka-streams

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

Use topology builder to pass in state store to wordcount example #34

Closed ah- closed 7 years ago

ah- commented 7 years ago

One tiny step closer towards proper state support - instantiate the state used by the wordcount example with the topology builder.

This lets us then later inject a different state store implementation, for example one that logs state changes to a topic.