1ccdccddaa
Emulate vhost support by adding the virtual host name to the topic created on the kafka server. Also, update connection management for producer/consumer. This patch: * updates target to topic generation * add consumer and producer connection classes * remove connection pool * update driver test Change-Id: Idd164444c04e9f465a43ee909af840a41bb090c0 |
||
---|---|---|
.. | ||
drivers | ||
functional | ||
notify | ||
rpc | ||
__init__.py | ||
test_config_opts_proxy.py | ||
test_exception_serialization.py | ||
test_expected_exceptions.py | ||
test_fixture.py | ||
test_opts.py | ||
test_target.py | ||
test_transport.py | ||
test_urls.py | ||
test_utils.py | ||
utils.py |