We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 025ef3b commit ecaf575Copy full SHA for ecaf575
1 file changed
README.md
@@ -30,13 +30,14 @@ from fluvio import Fluvio
30
fluvio = Fluvio.connect()
31
producer = fluvio.topic_producer('my-topic')
32
producer.send_string("FOOBAR")
33
+producer.flush()
34
```
35
36
## Consumer
37
```python
38
from fluvio import (Fluvio, Offset)
39
-consumer = fluvio.partition_consumer('my-topic-while', 0)
40
+consumer = fluvio.partition_consumer('my-topic', 0)
41
stream = consumer.stream(Offset.beginning())
42
43
for i in stream:
0 commit comments