Skip to content

Instantly share code, notes, and snippets.

'''
To stream from Kafka, please refer to the streamz API here: https://streamz.readthedocs.io/en/latest/api.html#sources
You can refer to https://kafka.apache.org/quickstart to start a local Kafka cluster.
Below is an example snippet to start a stream from Kafka.
'''
from custreamz import kafka
# Kafka topic to read streaming data from
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
@chinmaychandak
chinmaychandak / custreamz-CCU-state-management.ipynb
Created April 24, 2020 17:54
custreamz-CCU-state-management
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
@chinmaychandak
chinmaychandak / custreamz_distributed_word_count.ipynb
Last active October 30, 2020 17:58
cuStreamz Word Count @ Scale
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.