How to use the faust.App function in faust
To help you get started, we’ve selected a few faust examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
marcosschroh / cookiecutter-faust / {{cookiecutter.project_slug}} / {{cookiecutter.project_slug}} / app.py View on Github 
import faust
from simple_settings import settings
app = faust.App(
id=1,
debug=settings.DEBUG,
autodiscover=["page_views"],
broker=settings.KAFKA_BOOTSTRAP_SERVER,
store=settings.STORE_URI,
logging_config=settings.LOGGING,
topic_allow_declare=settings.TOPIC_ALLOW_DECLARE,
topic_disable_leader=settings.TOPIC_DISABLE_LEADER,
broker_credentials=settings.SSL_CONTEXT,
)from streaming.config import config
import faust
app = faust.App(config['stream']['name'],
broker=config['stream']['host'],
autodiscover=[config['stream']['app']],
store='rocksdb://',
topic_partitions=4,
stream_wait_empty=False)
