Skip to content

Commit f439c2a

Browse files
authored
Added flush() call to AvroProducer example (closes confluentinc#221)
1 parent d516506 commit f439c2a

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ key = {"name": "Key"}
7878

7979
avroProducer = AvroProducer({'bootstrap.servers': 'mybroker,mybroker2', 'schema.registry.url': 'http://schem_registry_host:port'}, default_key_schema=key_schema, default_value_schema=value_schema)
8080
avroProducer.produce(topic='my_topic', value=value, key=key)
81+
avroProducer.flush()
8182
```
8283

8384
**AvroConsumer**

0 commit comments

Comments
 (0)