def __init__(self, bootstrap_servers):
self._producer = confluent_kafka.Producer({'<STR_LIT>':<EOL>bootstrap_servers})<EOL>
Create new Producer wrapper instance.

:param str bootstrap_servers: Initial list of brokers as a CSV
list of broker host or host:port.