def __init__(self, bootstrap_servers, group_id, topic,<EOL>fetch_min_bytes=<NUM_LIT>, client_id="<STR_LIT>",<EOL>repartition_callback=None, commit_callback=None,<EOL>max_commit_interval=<NUM_LIT:30>):
consumer_config = {'<STR_LIT>': bootstrap_servers,<EOL>'<STR_LIT>': group_id,<EOL>'<STR_LIT>': fetch_min_bytes,<EOL>'<STR_LIT>': client_id,<EOL>'<STR_LIT>': False,<EOL>'<STR_LIT>':<EOL>{'<STR_LIT>': '<STR_LIT>'}<EOL>}<EOL>self._commit_callback = commit_callback<EOL>self._max_commit_interval = max_commit_interval<EOL>self._consumer = confluent_kafka.Consumer(consumer_config)<EOL>self._consumer.subscribe([topic], on_revoke=repartition_callback)<EOL>self._last_commit = None<EOL>
Create new high-level Consumer instance.

:param list(str) bootstrap_servers: A list of host/port pairs to use
for establishing the initial connection to the Kafka cluster.
:param str group_id: A unique string that identifies the consumer group
this consumer belongs to.
:param str topic: Topic to subscribe to.
:param int fetch_min_bytes: The minimum amount of data the server
should return for a fetch request.
:param str client_id: An id string to pass to the server when making
requests.
:param callable repartition_callback: Callback function executed on the
start of a rebalance operation.
:param callable commit_callback: Callback function responsible for
calling the commit() method.
:param int max_commit_interval: Maximum time in seconds between commits.