You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
def_individual_message_commit(offline_ingestors, consumer, logger):
logger.info("{} offline ingestors running".format(len(offline_ingestors)))
forjob_id, job_iteminoffline_ingestors.items():
result=job_item["proc"].poll()
ifresultisnotNone:
logger.info("Offline ingestor for job id {} ended with result {}".format(job_id,result))
ifresult==0:
logger.info("Executing commit for message with job id {}".format(job_id))
consumer.commit(message=job_item["message"])
logger.info("Removed ingestor for message with job id {} from queue".format(job_id))
Currently this code is run only when config.kafka.individual_message_commit option is active.
But it has some logging lines that need to be run always.
The text was updated successfully, but these errors were encountered:
Currently this code is run only when
config.kafka.individual_message_commit
option is active.But it has some logging lines that need to be run always.
The text was updated successfully, but these errors were encountered: