joaoferrao

import faust

app = faust.App(id="test",broker="kafka://localhost:9092",store="memory://")

# convenience func for launching the app
def main() -> None:
    app.main()

# Input topic, NOT managed by Faust. Marked
input_topic = app.topic('input', internal=False, partitions=1, value_type=str)