Open shamanu4 opened 4 years ago
Issue can be reproduced on the latest stable commit in master - 8d61a78c76a096597421a8e9db2878d4381dd6a
pip install git+https://github.com/robinhood/faust@38d61a78c76a096597421a8e9db2878d4381dd6a
Create an app with agent. The example from the quick start is enough.
import faust app = faust.App( 'hello-world', broker='kafka://localhost:9092', value_serializer='raw', ) greetings_topic = app.topic('greetings') @app.agent(greetings_topic) async def greet(greetings): async for greeting in greetings: print(greeting)
faust -A hello_world worker -l warn
kafka-console-producer --broker-list localhost:9092 --topic greetings >hello
kafka-consumer-groups --bootstrap-server localhost:9092 --group hello-world --reset-offsets --to-latest --execute --all-topics
kafka-console-producer --broker-list localhost:9092 --topic greetings >hello 1, will be ignored >hello 2, will be printed
┌ƒaµS† v1.11.0a1────────────────────────────────────────────────────────┐ │ id │ hello-world │ │ transport │ [URL('kafka://localhost:9092')] │ │ store │ memory: │ │ web │ http://maxims-macbook-pro.local:6066 │ │ log │ -stderr- (warn) │ │ pid │ 49793 │ │ hostname │ Maxims-MacBook-Pro.local │ │ platform │ CPython 3.8.0 (Darwin x86_64) │ │ drivers │ │ │ transport │ aiokafka=1.1.6 │ │ web │ aiohttp=3.6.2 │ │ datadir │ /Users/shamanu4/projects/faust_test/hello-world-data │ │ appdir │ /Users/shamanu4/projects/faust_test/hello-world-data/v1 │ └─────────────┴─────────────────────────────────────────────────────────┘ starting➢ 😊 [2020-07-21 12:51:38,541] [49793] [WARNING] b'hello 1, will be ignored' [2020-07-21 12:51:39,399] [49793] [WARNING] b'hello 2, will be printed'
┌ƒaµS† v1.11.0a1────────────────────────────────────────────────────────┐ │ id │ hello-world │ │ transport │ [URL('kafka://localhost:9092')] │ │ store │ memory: │ │ web │ http://maxims-macbook-pro.local:6066 │ │ log │ -stderr- (warn) │ │ pid │ 49793 │ │ hostname │ Maxims-MacBook-Pro.local │ │ platform │ CPython 3.8.0 (Darwin x86_64) │ │ drivers │ │ │ transport │ aiokafka=1.1.6 │ │ web │ aiohttp=3.6.2 │ │ datadir │ /Users/shamanu4/projects/faust_test/hello-world-data │ │ appdir │ /Users/shamanu4/projects/faust_test/hello-world-data/v1 │ └─────────────┴─────────────────────────────────────────────────────────┘ starting➢ 😊 [2020-07-21 12:51:39,399] [49793] [WARNING] b'hello 2, will be printed'
Reopen. Merge was done in the fork
Checklist
Issue can be reproduced on the latest stable commit in master - 8d61a78c76a096597421a8e9db2878d4381dd6a
Steps to reproduce
pip install git+https://github.com/robinhood/faust@38d61a78c76a096597421a8e9db2878d4381dd6a
Create an app with agent. The example from the quick start is enough.
Expected behavior
Actual behavior
Versions