(self, topics, client_id, strict=False, num_processes=1,
                 process_num=0, dedicated_migration_process=False,)
Create a change feed listener for a list of kafka topics, a client ID, and partition.

        See http://kafka.apache.org/documentation.html#introduction for a description of what these are.
Create a change feed listener for a list of kafka topics, a client ID, and partition.
Create a change feed listener for a list of kafka topics a client ID and partition .
def __init__(self, topics, client_id, strict=False, num_processes=1,
                 process_num=0, dedicated_migration_process=False,):
        """
        Create a change feed listener for a list of kafka topics, a client ID, and partition.

        See http://kafka.apache.org/documentation.html#introduction for a description of what these are.
        """
        self._topics = topics
        self._client_id = client_id
        self._processed_topic_offsets = {}
        self.strict = strict
        self.num_processes = num_processes
        self.process_num = process_num
        self.dedicated_migration_process = dedicated_migration_process
        self._consumer = None
def __init__ ( self , topics , client_id , strict = False , num_processes = 1 , process_num = 0 , dedicated_migration_process = False , ) : self . _topics = topics self . _client_id = client_id self . _processed_topic_offsets = { } self . strict = strict self . num_processes = num_processes self . process_num = process_num self . dedicated_migration_process = dedicated_migration_process self . _consumer = None