| commit | 19e1cc2e5734d96f77d2acd41c6d7d2a48ad61a1 | [log] [tgz] |
|---|---|---|
| author | Zack Williams <zdw@opennetworking.org> | Mon Nov 05 23:18:41 2018 -0700 |
| committer | Zack Williams <zdw@opennetworking.org> | Tue Nov 06 18:08:37 2018 -0700 |
| tree | 15041fc0b15ff28cd913caeba6679c05afd2f7a7 | |
| parent | 1f300020727df22fbafdc7e957907a30c91c91a8 [diff] |
Use kafka producer properly
Calling producer.poll() is required or producer will fail with:
BufferError: Local: Queue full, instance_id: ...
Add 'extra_config' parameter to extend configuration of the kafka producer
Update tests/docs
Change-Id: I8f17437c0c24d61a6f3be5de3d4004c21fcad75a