def consume(data: PydanticLogModel) -> None: stream_logger.info(data.json()) async with app: logger.debug("Log Message", UserLog(user="kafkaesk")) await app.flush() await app.consume_for(1, seconds=5)
