.coveragerc
.gitignore
.travis.yml
AUTHORS.md
CHANGELOG.md
LICENSE.txt
README.md
requirements.txt
setup.cfg
setup.py
test-requirements.txt
tox.ini
docs/Makefile
docs/authors.rst
docs/changelog.rst
docs/conf.py
docs/index.rst
docs/license.rst
docs/_static/.gitignore
examples/simple_consumer.py
kafka_tfrx/__init__.py
kafka_tfrx/observer.py
kafka_tfrx/stream.py
kafka_tfrx.egg-info/PKG-INFO
kafka_tfrx.egg-info/SOURCES.txt
kafka_tfrx.egg-info/dependency_links.txt
kafka_tfrx.egg-info/entry_points.txt
kafka_tfrx.egg-info/top_level.txt
tests/__init__.py
tests/conftest.py
tests/test_setup_streamer.py
tests/sample_schemas/gdax.avsc
tests/sample_schemas/keyschema.avsc
tests/sample_schemas/reddit.avsc
tests/sample_schemas/twitter.avsc